登录
注册
开源
企业版
高校版
搜索
帮助中心
使用条款
关于我们
开源
企业版
高校版
私有云
Gitee AI
NEW
我知道了
查看详情
登录
注册
12月28日，「开源中国源创会年终盛典」珠海站再次回归！点击免费报名参会
代码拉取完成，页面将自动刷新
开源项目
>
服务器应用
>
大数据
&&
捐赠
捐赠前请先登录
取消
前往登录
扫描微信二维码支付
取消
支付完成
支付提示
将跳转至支付宝完成支付
确定
取消
Watch
不关注
关注所有动态
仅关注版本发行动态
关注但不提醒动态
48
Star
354
Fork
156
tenmg
/
Clink
代码
Issues
2
Pull Requests
0
Wiki
统计
流水线
服务
Gitee Pages
JavaDoc
质量分析
Jenkins for Gitee
腾讯云托管
腾讯云 Serverless
悬镜安全
阿里云 SAE
Codeblitz
我知道了，不再自动展开
发行版
最新版
v1.6.1
1728255
2024-04-29 18:59
对比
v1.6.1
tenmg
#### 修复问题： - 修复当对象映射为java.util.Date类型时 JDBC 查询得到结果只有日期部分的问题； #### 优化改进： - 多表数据同步增加新的参数支持（参数含义详见 Flink CDC 官方文档） - clink-cdc-mysql 增加 `scan.incremental.close-idle-reader.enabled` 和 `scan.incremental.snapshot.backfill.skip` 参数支持； - clink-cdc-sqlserver 增加 `scan.incremental.snapshot.chunk.key-column`、`scan.incremental.close-idle-reader.enabled` 和 `scan.incremental.snapshot.backfill.skip` 参数支持； - 增加了 clink-cdc-postgres、clink-cdc-oracle 模块，分别支持以下源连接器的单作业多表数据同步： | 产品 | 适配版本 |----------------|------ | mysql-postgres | 2.2+ | oracle-cdc | 2.3+ - 升级依赖组件
最后提交信息为：
更新文档
v1.5.7
75c32ba
2024-02-29 19:15
对比
v1.5.7
tenmg
#### 修复问题： - 修复当对象映射为java.util.Date类型时JDBC查询得到结果只有日期部分的问题 #### 优化改进： - 升级依赖组件
最后提交信息为：
1.5.7
v1.6.0
6a9356b
2023-09-20 10:38
对比
v1.6.0
tenmg
#### 新增特性： - 升级 [dsl](https://gitee.com/tenmg/dsl) 至 1.4.1 后，SQL 中的宏支持两种代码执行引擎 JavaScript 和 Beanshell，默认为 JavaScript，如需调整需调整 dsl.properties 配置文件，详情参考 [dsl](https://gitee.com/tenmg/dsl) 文档； - 升级 [dsl](https://gitee.com/tenmg/dsl) 至 1.4.1 后，ObjectUtils 涉及的 JDK 废弃代码端进行了重构，可适应更高版本的 JDK ； - 增加了 clink-cdc-mysql、clink-cdc-sqlserver 模块，分别支持以下源连接器的多表数据同步： | 产品 | 适配版本 |---------------|------ | mysql-cdc | 2.2+ | sqlserver-cdc | 2.4+ #### 优化改进： - 升级 [dsl](https://gitee.com/tenmg/dsl) 至 1.4.1 后，修复“.”和“[]”参数访问符无法使用的问题。
最后提交信息为：
update README.md.
v1.5.6
542cbe7
2023-06-27 01:36
对比
v1.5.6
tenmg
#### 新增特性： - 开始支持配置加载器扩展，并默认提供使用 Nacos 配置中心的配置加载器实现。 #### 优化改进： - 升级dsl至1.3.4，修复未能正确识别多行注释结束符的问题； - 完善 `<jdbc>` 的查询支持，并优化 JDBC 驱动注册方式； - 增加自动生成数据源的缓存，避免每次执行都重新生成，提升运行效率。
最后提交信息为：
update README.md.
v1.5.5
4afaef5
2022-12-08 11:11
对比
v1.5.5
tenmg
#### 优化改进： 1. 修复在并行解析配置时，由于重用Unmarshaller带来的线程安全问题; 2. 优化客户端代码。
最后提交信息为：
修复在并行解析配置时，由于重用Unmarshaller带来的线程安全问题
v1.5.4
a1e1129
2022-12-02 15:48
对比
v1.5.4
tenmg
#### 优化改进： 1. 优化客户端提交任务获取执行JAR和主类的优先顺序：配置JAR时，不使用flink.jobs.default.class配置作为主类; 2. 优化元数据获取，程序入口，自动创建数据源日志等代码。
最后提交信息为：
update README.md.
v1.5.3
2bf760e
2022-12-01 09:55
对比
v1.5.3
tenmg
#### 新增特性： - flink-jobs-clients支持并且优先使用`rest.addresses`或者`rest.address`配置作业提交的主机地址。 #### 优化改进： - 优化任务中配置的加载，支持properties语法（暂不支持换行）。
最后提交信息为：
Merge remote-tracking branch 'origin/master' into dev
v1.5.2
b4a71ac
2022-11-16 13:26
对比
v1.5.2
tenmg
#### 新增特性： 1. 增加SimpleFlinkJobsRunner，并增加默认flink-jobs程序入口FlinkJobsPortal。 2. <data-sync>的<from-config>和<to-config>标签支持[DSL](https://gitee.com/tenmg/dsl)语法。
最后提交信息为：
的和标签支持DSL语法
v1.5.1
d14787c
2022-11-02 15:29
对比
v1.5.1
tenmg
#### 优化改进： - 修复StandaloneRestClusterClient提交仅含bsh、jdbc任务异常的问题。
最后提交信息为：
Merge branch 'master' of
https://gitee.com/tenmg/flink-jobs.git
v1.5.0
80d5a51
2022-11-02 09:55
对比
v1.5.0
tenmg
#### 新增特性： 1. 增加数据源过滤功能，让数据源一次配置多场景使用。 2. 客户端实例化支持指定配置文件，不同实例可使用不同配置文件，可实现多集群提交任务。 #### 优化改进： 1. 修复普通flink jar无法通过StandaloneRestClusterClient提交的问题； 2. 优化了客户端相关实现代码。
最后提交信息为：
update README.md.
v1.4.3
4373185
2022-10-20 15:30
对比
v1.4.3
tenmg
#### 优化改进： 1. `<jdbc>`支持StarRocks flink connector的`jdbc-url`作为自动数据源的地址； 2. 支持flink-jobs-clients程序仅配置提交的主类而不一定要配置提交的JAR包； 3. 优化部分代码。
最后提交信息为：
支持flink-jobs-clients程序仅配置提交的主类而不一定要配置提交的JAR包；优化部分代码。
v1.4.2
d20b111
2022-10-14 10:52
对比
v1.4.2
tenmg
#### 优化改进： 1. jdbc标签取消数据库连接池的支持，修复因此引起的反复初始化连接池且不释放导致连接占满的问题； 2. 修复StandaloneRestClusterClient提交任务后未正确释放资源（未调用packagedProgram.close()）导致资源不释放的问题; 3. 修复<jdbc>的resultClass属性不生效的问题； 4. 优化部分代码
最后提交信息为：
修复的resultClass属性不生效的问题
v1.4.1
34ff78a
2022-10-08 18:00
对比
v1.4.1
tenmg
#### 新增特性： - 可使用`jdbc.default_method`配置指定默认执行的JDBC方法。 #### 优化改进： - 将默认执行的JDBC方法由`executeLargeUpdate`改为`executeUpdate`（由于很多数据库连接池或者JDBC驱动未实现`executeLargeUpdate`方法），但支持用户使用`jdbc.default_method`配置指定。
最后提交信息为：
调整执行的默认JDBC方法
v1.4.0
047ee5e
2022-09-29 13:57
对比
v1.4.0
tenmg
#### 新增特性： 1. 所有标签支持使用`when`属性配置执行条件，执行条件采用JavaScript引擎实现，使用JavaScript语法； 2. `<data-sync>`标签内部增加`<complex-column>`标签，用于配置复杂数据类型，如`MAP<STRING,STRING>`； 3. 使用`<jdbc>`标签执行JDBC支持使用数据库连接池； 4. 使用`<jdbc>`标签执行JDBC支持查询单个对象（`method="get"`）和对象列表（`method="select"`）。对象的类型可通过`resultClass`属性配置，默认为`java.util.HashMap`； 5. 开始支持自动数据源，方便数据仓库（或数据湖）的建设。 #### 优化改进： 1. flink-jobs-config中，使用JAXB的接口解析XML时，改为单例模式； 2. 数据源相关代码优化，并统一添加默认表名的入口。 3. 对flink cdc支持更友好。
最后提交信息为：
修正注释
v1.3.4
2bf562d
2022-08-03 11:10
对比
v1.3.4
tenmg
#### 优化改进 修复`<execute-sql>`不指定`dataSource`时，SQL中无法使用参数的问题
最后提交信息为：
升级依赖的组件
v1.3.3
9a9614d
2022-06-28 17:15
对比
v1.3.3
tenmg
#### 优化改进 1、增加`metadata.starrocks.catalog_as_schema`配置（默认为true），以规避StarRocks适配 MySQL JDBC驱动存在错误的问题。 2、fastjson 升级至2.0.8
最后提交信息为：
update README.md.
v1.3.2
05fc55a
2022-06-27 18:57
对比
v1.3.2
tenmg
#### 新增特性： - 增加`metadata.starrocks.unique_key_as_primary_key`配置（默认值为`true`），用于指示是否将获取的StarRocks元数据中的更新模型的`UNIQUE KEY`列作为主键`PRIMARY KEY`，以便自动生成的表（Source/Sink Table）含有主键信息，使得对应的Flink同步（或者写入）任务能够支持安全停止（`stopWithSavePoint`）； #### 优化改进： - 将元数据获取器提升为顶层模块，将cn.tenmg.flink.jobs.operator.data.sync包移动至cn.tenmg.flink.jobs.metadata，并将`data.sync.metadata.getter.*`配置改为`metadata.getter.*`。
最后提交信息为：
update README.md.
v1.3.1
bca46ed
2022-06-27 14:32
对比
v1.3.1
tenmg
#### 问题修复： - 修复StandaloneRestClusterClient.stop因为兼容flink 1.15引入的反射执行方法导致无法正常停止作业的问题。
最后提交信息为：
修复停止作业方法stop无法正常运行的问题
v1.3.0
165defa
2022-06-27 14:07
对比
v1.3.0
tenmg
#### 新增特性： 1. flink升级至1.15.0； 2. flink-jobs改为父项目，原flink-jobs改为flink-jobs-core模块； 3. flink-jobs-core相较flink-jobs 1.2.*新增了快速建表功能`CreateTable`； 4. flink-jobs-clients新增`<create-table>`与flink-jobs-core的`CreateTable`适配； 5. 由于智能模式适用场景的扩展，因此使用`flink.jobs.smart`配置替代原来的`data.sync.smart`。 #### 问题修复： 1. 修复提交任务仅含bsh和jdbc时报错的问题； 2. 修复一些其他已知问题。
最后提交信息为：
更新开发者
v1.2.3
af53ff8
2022-05-15 10:21
对比
v1.2.3
tenmg
1. 增加Flink SQL自动添加`table-name`配置； 2. 优化Flink SQL关键词配置。
最后提交信息为：
Merge remote-tracking branch 'origin/1.2'
下载
请输入验证码，防止盗链导致资源被占用
取消
下载
Java
1
https://gitee.com/tenmg/Clink.git
[email protected]
:tenmg/Clink.git
tenmg
Clink
Clink
点此查找更多帮助
搜索帮助
Git 命令在线学习
如何在 Gitee 导入 GitHub 仓库
Git 仓库基础操作
企业版和社区版功能对比
SSH 公钥设置
如何处理代码冲突
仓库体积过大，如何减小？
如何找回被删除的仓库数据
Gitee 产品配额说明
GitHub仓库快速导入Gitee及同步更新
什么是 Release（发行版）
将 PHP 项目自动发布到 packagist.org
评论
仓库举报
回到顶部
登录提示
该操作需登录 Gitee 帐号，请先登录后再操作。
立即登录
没有帐号，去注册
