130 Star 1.2K Fork 371

GVPApache StreamPark / StreamPark

2021-11-16 14:49
626961 benjobs 1578929627 benjobs

Change Log

New Feature

  1. Support for Flink on Kubernetes runtime including Application/Session mode.
  2. Support for automatic building Flink-K8s Application image from Flink SQL.
  3. StreamX instance no longer forces a dependency on the Hadoop environment.
  4. Flink-1.14 Support.

Enhance / Bug Fix

  1. HADOOP_USER_NAME can be specified in Flink on YARN mode.
  2. Optimize the authentication renewal logic of kerberos.
  3. Fix isolation-related bugs for multiple versions of Flink.
  4. Fix create view syntax bugs of Flink.
  5. Optimize the sql parse tool.
  6. Sql dialect bug fixed.
  7. new startup script. new add restart|status option.

更新日志

新特性

  1. 支持 Flink on Kubernetes 任务发布(包含 Application/Session Mode);
  2. 支持从 Flink SQL 自动构建 Flink-K8s Application 镜像;
  3. 于Hadoop解耦,不再强制依赖 Hadoop;
  4. 新增 Flink-1.14 支持(Flink-1.12,1.13,1.14);

优化 / Bug 修复

  1. Flink on YARN 环境下可指定 HADOOP_USER_NAME;
  2. 优化 kerberos 的认证续期逻辑;
  3. 修复 Flink 多版本的隔离相关 Bug;
  4. 修复Flink create view 等语法错误;
  5. 优化Flink Sql解析;
  6. 修复Flink Sql方言设置bug;
  7. 全新的启动脚本,新增 restart|status等操作.
    ...
Java
1
https://gitee.com/apache-streampark/streampark.git
git@gitee.com:apache-streampark/streampark.git
apache-streampark
streampark
StreamPark

搜索帮助