当前仓库属于暂停状态,部分功能使用受限,详情请查阅 仓库状态说明
6 Star 18 Fork 10

tenmg / flink-jobs-launcher
暂停

2022-05-15 15:58
7920102 tenmg 1616488730 tenmg

与flink-jobs 1.2.3配套发布,无更新。

最后提交信息为: 发布1.2.3
2022-05-14 10:01
7920102 tenmg 1616488730 tenmg

修复仅提交jdbc任务失败的问题

最后提交信息为: 修复仅提交jdbc任务失败的问题
2022-03-01 13:29
7920102 tenmg 1616488730 tenmg
  1. 跟随flink-jobs 1.2.1发布,无特别更新。
  2. 跟随flink-jobs 1.2.1中configuration规范的调整,对应的<configuration>规范相应调整。
最后提交信息为: update README.md.
2022-02-10 18:56
7920102 tenmg 1616488730 tenmg
  1. 优化了作业配置,增加<configuration>用于Flink作业的个性化配置,使得用户可以更加方便地指定作业的配置;
  2. flink-jobs中增加flink-jobs-clients模块,计划用于替换flink-jobs-launcher,后续flink-jobs-launcher可能不再更新;
  3. 将依赖的Flink升级至1.14.3,其它组件一并升级。
最后提交信息为: update README.md.
2022-01-25 14:22
7920102 tenmg 1616488730 tenmg

修复RestClusterClientFlinkJobsLauncher队列管理的错误(会导致OOM)

最后提交信息为: 完善代码
2021-12-20 16:33
7920102 tenmg 1616488730 tenmg
  1. RestClusterClientFlinkJobsLauncher可配置多个Flink远程调用地址,以便当某些任务管理器(TaskManager)宕机后可以提交任务到其他正常的任务管理器(TaskManager);
  2. 日志依赖改为slf4j-api,具体日志实现由用户选择(比如logback/log4j);
  3. 移除上个版本废弃的代码。
最后提交信息为: 移除废弃代码
2021-12-11 16:43
7920102 tenmg 1616488730 tenmg
  1. 新增基于flink远程过程调用(RPC)提交任务的启动类RestClusterClientFlinkJobsLauncher,使用该类提交任务不再需要将启动程序安装在flink集群的服务器上;
  2. 增加数据同步自动添加时间戳列的配置,用于配置同步数据时写入的时间戳列,包括事件时间、摄取时间、处理时间;
  3. 分离出flink-jobs-config模块,以便用户单独使用,进行其它深度集成。
最后提交信息为: update README.md.
2021-11-18 14:22
7920102 tenmg 1616488730 tenmg

修复<data-sync>自定义主键(primaryKey)不生效的问题

2021-10-15 18:08
7920102 tenmg 1616488730 tenmg
  1. 新增数据同步配置标签<data-sync>,实现基于Debezuim的数据同步,以便简化通过<execute-sql>实现的数据同步功能;
  2. 解决配置SQL带“`”字符启动异常的问题。
最后提交信息为: update README.md.
2021-08-16 13:15
7920102 tenmg 1616488730 tenmg
  1. 增加<jdbc>标签用于配置执行基于DSL的JDBC SQL;
  2. 增加stop(jobId)方法,用于根据jobId停止任务;
  3. 增加allwaysNewJob配置项,用于确定是否忽略--fromSavepoint选项。这对于任务启动时确定任务是从保存点重启运行还是作为新任务开始运行很有帮助。
最后提交信息为: update README.md.
2021-08-04 16:35
7920102 tenmg 1616488730 tenmg

1.优化了运行参数解析;
2.开始支持基于DSL(Dynamic Script Language,动态脚本语言)的Flink SQL

最后提交信息为: update README.md.
2021-07-04 10:02
7920102 tenmg 1616488730 tenmg

优化代码和schema

最后提交信息为: Update pom.xml
2021-06-24 16:08
7920102 tenmg 1616488730 tenmg
  1. Linux环境执行时,自动加载系统环境变量;
  2. 优化了执行信息获取,并输出执行日志。
最后提交信息为: 优化代码
2021-06-22 18:16
7920102 tenmg 1616488730 tenmg

发布1.0.0

最后提交信息为: 提交 1.0.0
Java
1
https://gitee.com/tenmg/flink-jobs-launcher.git
git@gitee.com:tenmg/flink-jobs-launcher.git
tenmg
flink-jobs-launcher
flink-jobs-launcher

搜索帮助