代码拉取完成,页面将自动刷新
与flink-jobs 1.2.3配套发布,无更新。
修复仅提交jdbc任务失败的问题
configuration
规范的调整,对应的<configuration>
规范相应调整。<configuration>
用于Flink作业的个性化配置,使得用户可以更加方便地指定作业的配置;修复RestClusterClientFlinkJobsLauncher队列管理的错误(会导致OOM)
RPC
)提交任务的启动类RestClusterClientFlinkJobsLauncher
,使用该类提交任务不再需要将启动程序安装在flink集群的服务器上;flink-jobs-config
模块,以便用户单独使用,进行其它深度集成。修复<data-sync>
自定义主键(primaryKey
)不生效的问题
<data-sync>
,实现基于Debezuim的数据同步,以便简化通过<execute-sql>
实现的数据同步功能;<jdbc>
标签用于配置执行基于DSL的JDBC SQL;stop(jobId)
方法,用于根据jobId
停止任务;--fromSavepoint
选项。这对于任务启动时确定任务是从保存点重启运行还是作为新任务开始运行很有帮助。1.优化了运行参数解析;
2.开始支持基于DSL(Dynamic Script Language,动态脚本语言)的Flink SQL