Apache Flink 1.6.3 釋出,開源流處理框架
Apache Flink 1.6.3 已釋出,這是 1.6 系列的第三個修復版本,包含80項多項修復及改進,建議所有使用者升級。Apache Flink 是一個開源的流處理框架,應用於分散式、高效能、始終可用的、準確的資料流應用程式。
部分更新內容如下:
Improvement
[FLINK-4173] - Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics
[FLINK-10353] - Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint written with Semantic.AT_LEAST_ONCE fails with NPE
[FLINK-10608] - Add avro files generated by datastream-allround-test to RAT exclusions
[FLINK-10613] - Remove logger casts in HBaseConnectorITCase
[FLINK-10614] - Update test_batch_allround.sh e2e to new testing infrastructure
[FLINK-10637] - Start MiniCluster with random REST port
[FLINK-10678] - Add a switch to run_test to configure if logs should be checked for errors/excepions
[FLINK-10692] - Harden Confluent schema E2E test
[FLINK-10883] - Submitting a jobs without enough slots times out due to a unspecified timeout
[FLINK-10906] - docker-entrypoint.sh logs credentails during startup
[FLINK-10916] - Include duplicated user-specified uid into error message
[FLINK-10951] - Disable enforcing of YARN container virtual memory limits in tests
[FLINK-11005] - Define flink-sql-client uber-jar dependencies via artifactSet
Test
[FLINK-10606] - Construct NetworkEnvironment simple for tests
[FLINK-10607] - Unify to remove duplicated NoOpResultPartitionConsumableNotifier
[FLINK-10827] - Add test for duplicate() to SerializerTestBase
Wish
[FLINK-10793] - Change visibility of TtlValue and TtlSerializer to public for external tools
完整更新內容可查閱發行說明:
https://flink.apache.org/news/2018/12/22/release-1.6.3.html
下載地址:
https://flink.apache.org/downloads.html
<dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.6.3</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.11</artifactId> <version>1.6.3</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-clients_2.11</artifactId> <version>1.6.3</version> </dependency>