卷起來了，Apache Flink 1.13.6 發(fā)布！

Hi，我是王知無，一個大數(shù)據(jù)領(lǐng)域的原創(chuàng)作者。?

放心關(guān)注我，獲取更多行業(yè)的一手消息。

Apache Flink 社區(qū)發(fā)布了 Flink 1.13 的另一個錯誤修復(fù)版本。

此版本包括99個錯誤和漏洞修復(fù)以及 Flink 1.13 的小改進(jìn)，包括 Apache Log4j 的另一次升級（到 2.17.1）。您將在下面找到所有錯誤修復(fù)和改進(jìn)的列表（不包括對構(gòu)建基礎(chǔ)架構(gòu)和構(gòu)建穩(wěn)定性的改進(jìn)）。有關(guān)所有更改的完整列表，請參閱JIRA列表。

我們強(qiáng)烈建議所有用戶升級到 Flink 1.13.6。

新的Maven依賴

??org.apache.flink
??flink-java
??1.13.6


??org.apache.flink
??flink-streaming-java_2.11
??1.13.6


??org.apache.flink
??flink-clients_2.11
??1.13.6

修復(fù)漏洞

• [ FLINK-15987 ] - SELECT 1.0e0 / 0.0e0 拋出 NumberFormatException
• [ FLINK-17914 ] - 如果存檔列表失敗，HistoryServer 會刪除緩存的存檔
• [ FLINK-20195 ] - Jobs 端點(diǎn)返回重復(fù)的作業(yè)
• [ FLINK-20370 ] - sink 主鍵與查詢不同時結(jié)果錯誤
• [ FLINK-21289 ] - 應(yīng)用程序模式忽略 pipeline.classpaths 配置
• [ FLINK-23919 ] - PullUpWindowTableFunctionIntoWindowAggregateRule 為 Window TVF 生成無效的 Calc
• [ FLINK-24232 ] - 暫停作業(yè)的存檔可防止中斷后續(xù)存檔嘗試
• [ FLINK-24255 ] - 測試環(huán)境/迷你集群不轉(zhuǎn)發(fā)配置。
• [ FLINK-24310 ] - 文檔中 BufferingSink 示例中的錯誤
• [ FLINK-24318 ] - 將數(shù)字轉(zhuǎn)換為布爾值在“選擇”字段和“位置”條件之間有不同的結(jié)果
• [ FLINK-24334 ] - 配置 kubernetes.flink.log.dir 不起作用
• [ FLINK-24366 ] - 當(dāng)任務(wù)已被取消時，有關(guān)還原失敗的不必要/誤導(dǎo)性錯誤消息。
• [ FLINK-24401 ] - Metaspace OOM 后 TM 無法退出
• [ FLINK-24465 ] - 緩沖區(qū)超時的錯誤 javadoc 和文檔
• [ FLINK-24492 ] - numeric 和 (var)char 之間不正確的隱式類型轉(zhuǎn)換
• [ FLINK-24506 ] - 檢查點(diǎn)目錄無法通過傳遞給 StreamExecutionEnvironment 的 Flink 配置進(jìn)行配置
• [ FLINK-24509 ] - 由于使用了不正確的構(gòu)造函數(shù)簽名，F(xiàn)linkKafkaProducer 示例未編譯
• [ FLINK-24540 ] - 修復(fù) Files.list 導(dǎo)致的資源泄漏
• [ FLINK-24543 ] - Zookeeper 連接問題導(dǎo)致 Flink 中的狀態(tài)不一致
• [ FLINK-24563 ] - 將 timstamp_ltz 與隨機(jī)字符串進(jìn)行比較會拋出 NullPointerException
• [ FLINK-24597 ] - RocksdbStateBackend getKeysAndNamespaces 在使用 MapState 時會返回重復(fù)數(shù)據(jù)
• [ FLINK-24621 ] - 由于 InflightDataRescalingDescriptor，JobManager 無法恢復(fù) 1.13.1 檢查點(diǎn)
• [ FLINK-24662 ] - PyFlink sphinx 檢查失敗，"節(jié)點(diǎn)類 'meta' 已注冊，其訪問者將被覆蓋"
• [ FLINK-24667 ] - 如果之前遇到異常，通道狀態(tài)編寫器將直接失敗任務(wù)
• [ FLINK-24676 ] - 如果用部分列解釋插入語句，則架構(gòu)不匹配
• [ FLINK-24678 ] - 更正地圖狀態(tài)的度量名稱包含延遲
• [ FLINK-24708 ] - ConvertToNotInOrInRule 有一個導(dǎo)致錯誤結(jié)果的錯誤
• [ FLINK-24728 ] - 批處理 SQL 文件接收器忘記關(guān)閉輸出流
• [ FLINK-24761 ] - 修復(fù) PartitionPruner 代碼生成編譯失敗
• [ FLINK-24846 ] - AsyncWaitOperator 在 stop-with-savepoint 期間失敗
• [ FLINK-24860 ] - 修復(fù) Python UDTF 中錯誤的位置映射
• [ FLINK-24885 ] - ProcessElement 接口參數(shù)收集器：java.lang.NullPointerException
• [ FLINK-24922 ] - 修復(fù)單詞“parallism”中的拼寫錯誤
• [ FLINK-25022 ] - 通過 REST API 提交作業(yè)時，JM 上的 ThreadLocals 的 ClassLoader 泄漏
• [ FLINK-25067 ] - 更正 RocksDB 后臺線程的描述
• [ FLINK-25084 ] - 字段名稱必須是唯一的。找到重復(fù)項
• [ FLINK-25091 ] - 官網(wǎng)文檔FileSink orc壓縮屬性引用錯誤
• [ FLINK-25096 ] - flink 1.13.2 中的異常 API(/jobs/:jobid/exceptions) 中的問題
• [ FLINK-25199 ] - StreamEdges 在自聯(lián)合中不是唯一的，它會阻止水印的傳播
• [ FLINK-25362 ] - Table Confluent/Avro 文檔中的依賴關(guān)系不正確
• [ FLINK-25468 ] - 如果本地狀態(tài)存儲和 RocksDB 工作目錄不在同一個卷上，則本地恢復(fù)失敗
• [ FLINK-25486 ] - 當(dāng) zookeeper 領(lǐng)導(dǎo)者改變時，Perjob 無法從檢查點(diǎn)恢復(fù)
• [ FLINK-25494 ] - DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources 期間重復(fù)的元素序列化程序
• [ FLINK-25513 ] - CoFlatMapFunction 需要兩個 flat_map 才能產(chǎn)生一些東西
• [ FLINK-25559 ] - SQL JOIN 導(dǎo)致數(shù)據(jù)丟失
• [ FLINK-25683 ] - 如果表轉(zhuǎn)換為 DataStream 則結(jié)果錯誤，然后在批處理模式下進(jìn)行窗口處理
• [ FLINK-25728 ] - StreamMultipleInputProcessor 中潛在的內(nèi)存泄漏
• [ FLINK-25732 ] - Dispatcher#requestMultipleJobDetails 返回不可序列化的集合

改進(jìn)

• [ FLINK-21407 ] - 明確哪些來源和 API 支持哪些格式
• [ FLINK-20443 ] - ContinuousProcessingTimeTrigger 不會在窗口結(jié)束時觸發(fā)
• [ FLINK-21467 ] - 記錄 Bounded{One/Multi}Input.endInput 的可能推薦用法，并強(qiáng)調(diào)它們可以被多次調(diào)用
• [ FLINK-23842 ] - 為讀者注冊和拆分請求添加日志消息。
• [ FLINK-24631 ] - 避免直接使用標(biāo)簽作為部署和服務(wù)的選擇器
• [ FLINK-24739 ] - 在文檔中說明 Flink 的應(yīng)用模式的要求
• [ FLINK-24987 ] - 增強(qiáng) ExternalizedCheckpointCleanup 枚舉
• [ FLINK-25160 ] - 使文檔清晰：可容忍失敗檢查點(diǎn)計數(shù)連續(xù)失敗
• [ FLINK-25415 ] - 實(shí)現(xiàn)對 Cassandra 容器連接的重試
• [ FLINK-25611 ] - 移除 CoordinatorExecutorThreadFactory 線程創(chuàng)建保護(hù)
• [ FLINK-25818 ] - 添加解釋當(dāng)并行度高于分區(qū)數(shù)時 Kafka Source 如何處理空閑

技術(shù)債務(wù)

• [ FLINK-24740 ] - 將 testcontainers 依賴更新到 v1.16.2
• [ FLINK-24796 ] - 從 CI 編譯工件中排除 javadocs / node[_modules] 目錄
• [ FLINK-25472 ] - 更新到 Log4j 2.17.1
• [ FLINK-25375 ] - 將 Log4j 更新到 2.17.0
• [ FLINK-25576 ] - 將 com.h2database:h2 更新為 2.0.206