Apache Flink 1.10.3 Released

January 29, 2021 - Xintong Song

The Apache Flink community released the third bugfix version of the Apache Flink 1.10 series.

This release includes 36 fixes and minor improvements for Flink 1.10.2. The list below includes a detailed list of all fixes and improvements.

We highly recommend all users to upgrade to Flink 1.10.3.

Updated Maven dependencies:

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-java</artifactId>
  <version>1.10.3</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-streaming-java_2.11</artifactId>
  <version>1.10.3</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-clients_2.11</artifactId>
  <version>1.10.3</version>
</dependency>

You can find the binaries on the updated Downloads page.

List of resolved issues:

Bug

[FLINK-14087] - throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using RebalancePartitioner.
[FLINK-15170] - WebFrontendITCase.testCancelYarn fails on travis
[FLINK-15467] - Should wait for the end of the source thread during the Task cancellation
[FLINK-16246] - Exclude "SdkMBeanRegistrySupport" from dynamically loaded AWS connectors
[FLINK-17341] - freeSlot in TaskExecutor.closeJobManagerConnection cause ConcurrentModificationException
[FLINK-17458] - TaskExecutorSubmissionTest#testFailingScheduleOrUpdateConsumers
[FLINK-17677] - FLINK_LOG_PREFIX recommended in docs is not always available
[FLINK-18081] - Fix broken links in "Kerberos Authentication Setup and Configuration" doc
[FLINK-18196] - flink throws `NullPointerException` when executeCheckpointing
[FLINK-18212] - Init lookup join failed when use udf on lookup table
[FLINK-18832] - BoundedBlockingSubpartition does not work with StreamTask
[FLINK-18959] - Fail to archiveExecutionGraph because job is not finished when dispatcher close
[FLINK-19022] - AkkaRpcActor failed to start but no exception information
[FLINK-19109] - Split Reader eats chained periodic watermarks
[FLINK-19135] - (Stream)ExecutionEnvironment.execute() should not throw ExecutionException
[FLINK-19237] - LeaderChangeClusterComponentsTest.testReelectionOfJobMaster failed with "NoResourceAvailableException: Could not allocate the required slot within slot request timeout"
[FLINK-19401] - Job stuck in restart loop due to excessive checkpoint recoveries which block the JobMaster
[FLINK-19557] - Issue retrieving leader after zookeeper session reconnect
[FLINK-19675] - The plan of is incorrect when Calc contains WHERE clause, composite fields access and Python UDF at the same time
[FLINK-19901] - Unable to exclude metrics variables for the last metrics reporter.
[FLINK-20013] - BoundedBlockingSubpartition may leak network buffer if task is failed or canceled
[FLINK-20018] - pipeline.cached-files option cannot escape ':' in path
[FLINK-20033] - Job fails when stopping JobMaster
[FLINK-20065] - UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException
[FLINK-20076] - DispatcherTest.testOnRemovedJobGraphDoesNotCleanUpHAFiles does not test the desired functionality
[FLINK-20183] - Fix the default PYTHONPATH is overwritten in client side
[FLINK-20218] - AttributeError: module 'urllib' has no attribute 'parse'
[FLINK-20875] - [CVE-2020-17518] Directory traversal attack: remote file writing through the REST API

Improvement

[FLINK-16753] - Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException
[FLINK-18287] - Correct the documentation of Python Table API in SQL pages
[FLINK-19055] - MemoryManagerSharedResourcesTest contains three tests running extraordinary long
[FLINK-19105] - Table API Sample Code Error
[FLINK-19252] - Jaas file created under io.tmp.dirs - folder not created if not exists
[FLINK-19339] - Support Avro's unions with logical types
[FLINK-19523] - Hide sensitive command-line configurations

Apache Flink 1.10.3 Released

Bug

Improvement

Task