Apache Flink 1.5.5 和 1.6.2 釋出，通用資料處理平臺
Apache Flink 1.5.5 和 1.6.2 釋出了。Apache Flink 是一個開源的流處理框架，應用於分散式、高效能、始終可用的、準確的資料流應用程式。Apache Flink 也是高效和分散式的通用資料處理平臺。Apache Flink 宣告式的資料分析開源系統，結合了分散式 MapReduce 類平臺的高效，靈活的程式設計和擴充套件性。同時在並行資料庫發現查詢優化方案。
1.5.5 是 Apache Flink 1.5 系列的第五個 bugfix 版本，包括超過 20 個修復程式和一些小改進，強烈建議所有使用者升級到 Flink 1.5.5，主要改進如下：
改進
-
[ofollow,noindex" target="_blank">FLINK-10075 ] - HTTP connections to a secured REST endpoint flood the log
-
[FLINK-10260 ] - Confusing log messages during TaskManager registration
-
[FLINK-10282 ] - Provide separate thread-pool for REST endpoint
-
[FLINK-10312 ] - Wrong / missing exception when submitting job
-
[FLINK-10375 ] - ExceptionInChainedStubException hides wrapped exception in cause
-
[FLINK-10582 ] - Make REST executor thread priority configurable
Maven
<dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.5.5</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.11</artifactId> <version>1.5.5</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_2.11</artifactId> <version>1.5.5</version> </dependency>
1.6.2 是 Apache Flink 1.6 系列的第二個 bugfix 版本，包括超過 30 個修復程式和一些小改進，強烈建議所有使用者升級到 Flink 1.6.2，主要改進如下：
改進
-
[FLINK-9061 ] - Add entropy to s3 path for better scalability
-
[FLINK-10075 ] - HTTP connections to a secured REST endpoint flood the log
-
[FLINK-10260 ] - Confusing log messages during TaskManager registration
-
[FLINK-10282 ] - Provide separate thread-pool for REST endpoint
-
[FLINK-10291 ] - Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint
-
[FLINK-10311 ] - HA end-to-end/Jepsen tests for standby Dispatchers
-
[FLINK-10312 ] - Wrong / missing exception when submitting job
-
[FLINK-10371 ] - Allow to enable SSL mutual authentication on REST endpoints by configuration
-
[FLINK-10375 ] - ExceptionInChainedStubException hides wrapped exception in cause
-
[FLINK-10582 ] - Make REST executor thread priority configurable
Maven
<dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.6.2</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.11</artifactId> <version>1.6.2</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_2.11</artifactId> <version>1.6.2</version> </dependency>