Apache Flink 1.12.1有什么改進

這篇文章主要為大家展示了“Apache Flink 1.12.1有什么改進”，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學習一下“Apache Flink 1.12.1有什么改進”這篇文章吧。

Apache Flink 1.12 系列的首個 bug 修復版本 1.12.1 已經(jīng)發(fā)布。該版本包含 79 個修復和優(yōu)化，因此官方強烈建議所有用戶都升級到 1.12.1。

Maven 依賴

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

注意事項

• Apache Flink 1.12.1 的 DockerHub 官方鏡像暫時丟失。作為替代，這些鏡像目前放在 Flink PMC 的托管倉庫中。這也是目前 Native Kubernetes 部署的默認設(shè)置。Flink PMC 將繼續(xù)與 DockerHub 團隊合作以提供官方鏡像。

• 由于項目空間限制，PyPI 上暫時缺少 Apache Flink 1.12.1 的源代碼和 python 3.8 linux wheel 軟件包。目前，有關(guān)增加空間限制的請求正在 PyPI 審核過程中。在這段時間內(nèi)，用戶可以根據(jù)需要手動構(gòu)建軟件包。

部分更新內(nèi)容

• Sub-task

• 添加有關(guān) maxwell-json 格式的文檔

• 重做命令行接口文檔頁面

• 重做 PyFlink CLI 文檔

• Bug

• BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob 掛起

• 使用 Class.forName 時加載不同的驅(qū)動程序類時出現(xiàn)死鎖

• 由于超時而無法初始化 logger：引發(fā) LoggerInitializationException

• 修復 ignore-parse-errors 不適用于舊版 JSON 格式

• ZooKeeper quorum 因缺少 log4j 庫而無法啟動

• Improvement

• 日志開始/結(jié)束狀態(tài)恢復

• 將 “Flink Architecture” 頁面翻譯成中文

• 默認情況下啟用 log4j2 監(jiān)視間隔

以上是“Apache Flink 1.12.1有什么改進”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學習更多知識，歡迎關(guān)注億速云行業(yè)資訊頻道！