| --- |
| authors: |
| - jingsong: null |
| name: Jingsong Lee |
| date: "2021-08-06T00:00:00Z" |
| title: Apache Flink 1.12.5 Released |
| aliases: |
| - /news/2021/08/06/release-1.12.5.html |
| --- |
| |
| The Apache Flink community released the next bugfix version of the Apache Flink 1.12 series. |
| |
| This release includes 76 fixes and minor improvements for Flink 1.12.4. The list below includes a detailed list of all fixes and improvements. |
| |
| We highly recommend all users to upgrade to Flink 1.12.5. |
| |
| Updated Maven dependencies: |
| |
| ```xml |
| <dependency> |
| <groupId>org.apache.flink</groupId> |
| <artifactId>flink-java</artifactId> |
| <version>1.12.5</version> |
| </dependency> |
| <dependency> |
| <groupId>org.apache.flink</groupId> |
| <artifactId>flink-streaming-java_2.11</artifactId> |
| <version>1.12.5</version> |
| </dependency> |
| <dependency> |
| <groupId>org.apache.flink</groupId> |
| <artifactId>flink-clients_2.11</artifactId> |
| <version>1.12.5</version> |
| </dependency> |
| ``` |
| |
| You can find the binaries on the updated [Downloads page](/downloads.html). |
| |
| |
| Release Notes - Flink - Version 1.12.5 |
| |
| <h2> Bug |
| </h2> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-19925'>FLINK-19925</a>] - Errors$NativeIoException: readAddress(..) failed: Connection reset by peer |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-20321'>FLINK-20321</a>] - Get NPE when using AvroDeserializationSchema to deserialize null input |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-20888'>FLINK-20888</a>] - ContinuousFileReaderOperator should not close the output on close() |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-21329'>FLINK-21329</a>] - "Local recovery and sticky scheduling end-to-end test" does not finish within 600 seconds |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-21445'>FLINK-21445</a>] - Application mode does not set the configuration when building PackagedProgram |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-21469'>FLINK-21469</a>] - stop-with-savepoint --drain doesn't advance watermark for sources chained to MultipleInputStreamTask |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-21952'>FLINK-21952</a>] - Make all the "Connection reset by peer" exception wrapped as RemoteTransportException |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22015'>FLINK-22015</a>] - SQL filter containing OR and IS NULL will produce an incorrect result. |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22105'>FLINK-22105</a>] - SubtaskCheckpointCoordinatorTest.testForceAlignedCheckpointResultingInPriorityEvents unstable |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22157'>FLINK-22157</a>] - Join & Select a part of composite primary key will cause ArrayIndexOutOfBoundsException |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22312'>FLINK-22312</a>] - YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22408'>FLINK-22408</a>] - Flink Table Parsr Hive Drop Partitions Syntax unparse is Error |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22419'>FLINK-22419</a>] - testScheduleRunAsync fail |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22434'>FLINK-22434</a>] - Dispatcher does not store suspended jobs in execution graph store |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22443'>FLINK-22443</a>] - can not be execute an extreme long sql under batch mode |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22494'>FLINK-22494</a>] - Avoid discarding checkpoints in case of failure |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22496'>FLINK-22496</a>] - ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook failed |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22502'>FLINK-22502</a>] - DefaultCompletedCheckpointStore drops unrecoverable checkpoints silently |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22547'>FLINK-22547</a>] - OperatorCoordinatorHolderTest. verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22564'>FLINK-22564</a>] - Kubernetes-related ITCases do not fail even in case of failure |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22592'>FLINK-22592</a>] - numBuffersInLocal is always zero when using unaligned checkpoints |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22613'>FLINK-22613</a>] - FlinkKinesisITCase.testStopWithSavepoint fails |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22683'>FLINK-22683</a>] - The total Flink/process memory of memoryConfiguration in /taskmanagers can be null or incorrect value |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22698'>FLINK-22698</a>] - RabbitMQ source does not stop unless message arrives in queue |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22704'>FLINK-22704</a>] - ZooKeeperHaServicesTest.testCleanupJobData failed |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22721'>FLINK-22721</a>] - Breaking HighAvailabilityServices interface by adding new method |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22733'>FLINK-22733</a>] - Type mismatch thrown in DataStream.union if parameter is KeyedStream for Python DataStream API |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22756'>FLINK-22756</a>] - DispatcherTest.testJobStatusIsShownDuringTermination fail |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22788'>FLINK-22788</a>] - Code of equals method grows beyond 64 KB |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22814'>FLINK-22814</a>] - New sources are not defining/exposing checkpointStartDelayNanos metric |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22815'>FLINK-22815</a>] - Disable unaligned checkpoints for broadcast partitioning |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22819'>FLINK-22819</a>] - YARNFileReplicationITCase fails with "The YARN application unexpectedly switched to state FAILED during deployment" |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22820'>FLINK-22820</a>] - Stopping Yarn session cluster will cause fatal error |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22833'>FLINK-22833</a>] - Source tasks (both old and new) are not reporting checkpointStartDelay via CheckpointMetrics |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22856'>FLINK-22856</a>] - Move our Azure pipelines away from Ubuntu 16.04 by September |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22886'>FLINK-22886</a>] - Thread leak in RocksDBStateUploader |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22898'>FLINK-22898</a>] - HiveParallelismInference limit return wrong parallelism |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22908'>FLINK-22908</a>] - FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should wait until job is running |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22927'>FLINK-22927</a>] - Exception on JobClient.get_job_status().result() |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22946'>FLINK-22946</a>] - Network buffer deadlock introduced by unaligned checkpoint |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22952'>FLINK-22952</a>] - docs_404_check fail on azure due to ruby version not available |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22963'>FLINK-22963</a>] - The description of taskmanager.memory.task.heap.size in the official document is incorrect |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22964'>FLINK-22964</a>] - Connector-base exposes dependency to flink-core. |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22987'>FLINK-22987</a>] - Scala suffix check isn't working |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23010'>FLINK-23010</a>] - HivePartitionFetcherContextBase::getComparablePartitionValueList can return partitions that don't exist |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23030'>FLINK-23030</a>] - PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23045'>FLINK-23045</a>] - RunnablesTest.testExecutorService_uncaughtExceptionHandler fails on azure |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23074'>FLINK-23074</a>] - There is a class conflict between flink-connector-hive and flink-parquet |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23076'>FLINK-23076</a>] - DispatcherTest.testWaitingForJobMasterLeadership fails on azure |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23119'>FLINK-23119</a>] - Fix the issue that the exception that General Python UDAF is unsupported is not thrown in Compile Stage. |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23120'>FLINK-23120</a>] - ByteArrayWrapperSerializer.serialize should use writeInt to serialize the length |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23133'>FLINK-23133</a>] - The dependencies are not handled properly when mixing use of Python Table API and Python DataStream API |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23135'>FLINK-23135</a>] - Flink SQL Error while applying rule AggregateReduceGroupingRule |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23164'>FLINK-23164</a>] - JobMasterTest.testMultipleStartsWork unstable on azure |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23166'>FLINK-23166</a>] - ZipUtils doesn't handle properly for softlinks inside the zip file |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23182'>FLINK-23182</a>] - Connection leak in RMQSource |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23184'>FLINK-23184</a>] - CompileException Assignment conversion not possible from type "int" to type "short" |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23201'>FLINK-23201</a>] - The check on alignmentDurationNanos seems to be too strict |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23223'>FLINK-23223</a>] - When flushAlways is enabled the subpartition may lose notification of data availability |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23233'>FLINK-23233</a>] - OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure fails on azure |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23248'>FLINK-23248</a>] - SinkWriter is not closed when failing |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23417'>FLINK-23417</a>] - MiniClusterITCase.testHandleBatchJobsWhenNotEnoughSlot fails on Azure |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23429'>FLINK-23429</a>] - State Processor API failed with FileNotFoundException when working with state files on Cloud Storage |
| </li> |
| </ul> |
| |
| <h2> Improvement |
| </h2> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-17857'>FLINK-17857</a>] - Kubernetes and docker e2e tests could not run on Mac OS after migration |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-18182'>FLINK-18182</a>] - Upgrade AWS SDK in flink-connector-kinesis to include new region af-south-1 |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-20695'>FLINK-20695</a>] - Zookeeper node under leader and leaderlatch is not deleted after job finished |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-21229'>FLINK-21229</a>] - Support ssl connection with schema registry format |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-21411'>FLINK-21411</a>] - The components on which Flink depends may contain vulnerabilities. If yes, fix them. |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22708'>FLINK-22708</a>] - Propagate savepoint settings from StreamExecutionEnvironment to StreamGraph |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22747'>FLINK-22747</a>] - Update commons-io to 2.8 |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22757'>FLINK-22757</a>] - Update GCS documentation |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22774'>FLINK-22774</a>] - Update Kinesis SQL connector's Guava to 27.0-jre |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-22939'>FLINK-22939</a>] - Generalize JDK switch in azure setup |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23009'>FLINK-23009</a>] - Bump up Guava in Kinesis Connector |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23052'>FLINK-23052</a>] - cron_snapshot_deployment_maven unstable on maven |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23312'>FLINK-23312</a>] - Use -Dfast for building e2e tests on AZP |
| </li> |
| </ul> |
| |
