| --- |
| authors: |
| - knaufk: null |
| name: Konstantin Knauf |
| twitter: snntrable |
| date: "2022-03-11T08:00:00Z" |
| excerpt: The Apache Flink Community is please to announce another bug fix release |
| for Flink 1.14. |
| title: Apache Flink 1.14.4 Release Announcement |
| aliases: |
| - /news/2022/03/11/release-1.14.4.html |
| --- |
| |
| The Apache Flink Community is pleased to announce another bug fix release for Flink 1.14. |
| |
| This release includes 51 bug and vulnerability fixes and minor improvements for Flink 1.14. |
| Below you will find a list of all bugfixes and improvements (excluding improvements to the build infrastructure and build stability). For a complete list of all changes see: |
| [JIRA](https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12351074). |
| |
| We highly recommend all users to upgrade to Flink 1.14.4. |
| |
| # Release Artifacts |
| |
| ## Maven Dependencies |
| |
| ```xml |
| <dependency> |
| <groupId>org.apache.flink</groupId> |
| <artifactId>flink-java</artifactId> |
| <version>1.14.4</version> |
| </dependency> |
| <dependency> |
| <groupId>org.apache.flink</groupId> |
| <artifactId>flink-streaming-java_2.11</artifactId> |
| <version>1.14.4</version> |
| </dependency> |
| <dependency> |
| <groupId>org.apache.flink</groupId> |
| <artifactId>flink-clients_2.11</artifactId> |
| <version>1.14.4</version> |
| </dependency> |
| ``` |
| |
| ## Binaries |
| |
| You can find the binaries on the updated [Downloads page](/downloads.html). |
| |
| ## Docker Images |
| |
| * [library/flink](https://hub.docker.com/_/flink/tags?page=1&name=1.14.4) (official images) |
| * [apache/flink](https://hub.docker.com/r/apache/flink/tags?page=1&name=1.14.4) (ASF repository) |
| |
| ## PyPi |
| |
| * [apache-flink==1.14.4](https://pypi.org/project/apache-flink/1.14.4/) |
| |
| # Release Notes |
| |
| <h2> Sub-task |
| </h2> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-21788'>FLINK-21788</a>] - Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-24954'>FLINK-24954</a>] - Reset read buffer request timeout on buffer recycling for sort-shuffle |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25653'>FLINK-25653</a>] - Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid deadlock |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25654'>FLINK-25654</a>] - Remove the redundant lock in SortMergeResultPartition |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25879'>FLINK-25879</a>] - Track used search terms in Matomo |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25880'>FLINK-25880</a>] - Implement Matomo in Flink documentation |
| </li> |
| </ul> |
| |
| <h2> Bug |
| </h2> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-21752'>FLINK-21752</a>] - NullPointerException on restore in PojoSerializer |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-23946'>FLINK-23946</a>] - Application mode fails fatally when being shut down |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-24334'>FLINK-24334</a>] - Configuration kubernetes.flink.log.dir not working |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-24407'>FLINK-24407</a>] - Pulsar connector chinese document link to Pulsar document location incorrectly. |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-24607'>FLINK-24607</a>] - SourceCoordinator may miss to close SplitEnumerator when failover frequently |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25171'>FLINK-25171</a>] - When the DDL statement was executed, the column names of the Derived Columns were not validated |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25199'>FLINK-25199</a>] - StreamEdges are not unique in self-union, which blocks propagation of watermarks |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25362'>FLINK-25362</a>] - Incorrect dependencies in Table Confluent/Avro docs |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25407'>FLINK-25407</a>] - Network stack deadlock when cancellation happens during initialisation |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25466'>FLINK-25466</a>] - TTL configuration could parse in StateTtlConfig#DISABLED |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25486'>FLINK-25486</a>] - Perjob can not recover from checkpoint when zookeeper leader changes |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25494'>FLINK-25494</a>] - Duplicate element serializer during DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25678'>FLINK-25678</a>] - TaskExecutorStateChangelogStoragesManager.shutdown is not thread-safe |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25683'>FLINK-25683</a>] - wrong result if table transfrom to DataStream then window process in batch mode |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25728'>FLINK-25728</a>] - Potential memory leaks in StreamMultipleInputProcessor |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25732'>FLINK-25732</a>] - Dispatcher#requestMultipleJobDetails returns non-serialiable collection |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25827'>FLINK-25827</a>] - Potential memory leaks in SourceOperator |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25856'>FLINK-25856</a>] - Fix use of UserDefinedType in from_elements |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25883'>FLINK-25883</a>] - The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25893'>FLINK-25893</a>] - ResourceManagerServiceImpl's lifecycle can lead to exceptions |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25952'>FLINK-25952</a>] - Savepoint on S3 are not relocatable even if entropy injection is not enabled |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-26039'>FLINK-26039</a>] - Incorrect value getter in map unnest table function |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-26159'>FLINK-26159</a>] - Pulsar Connector: should add description MAX_FETCH_RECORD in doc to explain slow consumption |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-26160'>FLINK-26160</a>] - Pulsar Connector: stopCursor description should be changed. Connector only stop when auto discovery is disabled. |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-26187'>FLINK-26187</a>] - Chinese docs override english aliases |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-26304'>FLINK-26304</a>] - GlobalCommitter can receive failed committables |
| </li> |
| </ul> |
| |
| <h2> New Feature |
| </h2> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-20188'>FLINK-20188</a>] - Add Documentation for new File Source |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-21407'>FLINK-21407</a>] - Clarify which sources and APIs support which formats |
| </li> |
| </ul> |
| |
| <h2> Improvement |
| </h2> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-20830'>FLINK-20830</a>] - Add a type of HEADLESS_CLUSTER_IP for rest service type |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-24880'>FLINK-24880</a>] - Error messages "OverflowError: timeout value is too large" shown when executing PyFlink jobs |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25160'>FLINK-25160</a>] - Make doc clear: tolerable-failed-checkpoints counts consecutive failures |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25611'>FLINK-25611</a>] - Remove CoordinatorExecutorThreadFactory thread creation guards |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25650'>FLINK-25650</a>] - Document unaligned checkpoints performance limitations (larger records/flat map/timers/...) |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25767'>FLINK-25767</a>] - Translation of page 'Working with State' is incomplete |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25818'>FLINK-25818</a>] - Add explanation how Kafka Source deals with idleness when parallelism is higher then the number of partitions |
| </li> |
| </ul> |
| |
| <h2> Technical Debt |
| </h2> |
| <ul> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25576'>FLINK-25576</a>] - Update com.h2database:h2 to 2.0.206 |
| </li> |
| <li>[<a href='https://issues.apache.org/jira/browse/FLINK-25785'>FLINK-25785</a>] - Update com.h2database:h2 to 2.0.210 |
| </li> |
| </ul> |
