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

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

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

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

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

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

改進(jìn)

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