Apache Flink 1.5.1 发布,通用数据处理平台

王练
 王练
发布于 2018年07月14日
收藏 5

Apache Flink 1.5.1 是 1.5 系列的第一个 bug 修复版本。此版本包含针对 Flink 1.5.0 的 60 多项修复和改进。

亮点包括:

  • [FLINK-9153] - TaskManagerRunner should support rpc port range

  • [FLINK-9280] - Extend JobSubmitHandler to accept jar files

  • [FLINK-9316] - Expose operator unique ID to the user defined functions in DataStream .

  • [FLINK-9564] - Expose end-to-end module directory to test scripts

  • [FLINK-9599] - Implement generic mechanism to receive files via rest

  • [FLINK-9669] - Introduce task manager assignment store

  • [FLINK-9670] - Introduce slot manager factory

  • [FLINK-9671] - Add configuration to enable task manager isolation.

Maven 依赖

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-java</artifactId>
  <version>1.5.1</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-streaming-java_2.11</artifactId>
  <version>1.5.1</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-clients_2.11</artifactId>
  <version>1.5.1</version>
</dependency>
本站文章除注明转载外,均为本站原创或编译。欢迎任何形式的转载,但请务必注明出处,尊重他人劳动共创开源社区。
转载请注明:文章转载自 开源中国社区 [http://www.oschina.net]
本文标题:Apache Flink 1.5.1 发布,通用数据处理平台
加载中
返回顶部
顶部