由于考慮到項(xiàng)目后期需要用Flink對接Hive，所以這次項(xiàng)目升級需要將Flink版本由1.10升級到1.11，且保證項(xiàng)目能夠平穩(wěn)的運(yùn)行。 有人可能覺得框架版本升級很簡單，把p...
發(fā)簡信
IP屬地：陜西
-
快準(zhǔn)狠！解決jar包沖突問題 -
Apache Flink 1.10.0 重磅發(fā)布，年度最大規(guī)模版本升級！Flink 1.10 同時(shí)還標(biāo)志著對 Blink[1] 的整合宣告完成，隨著對 Hive 的生產(chǎn)級別集成及對 TPC-DS 的全面覆蓋，F(xiàn)link 在增強(qiáng)流式 SQL 處理能...
-
Flink如何快速定位SubTask在哪臺機(jī)器哪個(gè)進(jìn)程中執(zhí)行痛點(diǎn)：假如我們在FLink的WebUI Metrics頁面發(fā)現(xiàn)有一個(gè)SubTask每秒處理的數(shù)據(jù)明顯比其他低，又或者在CheckPoint頁面，發(fā)現(xiàn)有一個(gè)SubTask的Ch...
