- 26 Aug, 2022 2 commits
-
-
金鑫 authored
* sqlserver增加date类型数据转换规则. * sqlserver增加date类型数据转换规则. Co-authored-by:
金鑫 <jinyanhui@huansi.net>
-
rafael authored
-
- 25 Aug, 2022 2 commits
- 24 Aug, 2022 4 commits
-
-
windWheel authored
* The bug that the cluster information cannot be obtained in the savepoint save list * Add taskId in case dlink maintains sql * format code * enhance manage logic * 1. fix taskId is 0 2. reformat code * reformat code * refactor imports
-
金鑫 authored
* 增加sqlserver-cdc支持,可以通过手写finksql完成sqlservercdc同步,但是不支持cdcsource模式. * 修改报名\类名为sqlserver * 增加sqlserver-cdc支持,可以通过手写finksql完成sqlservercdc同步,但是不支持cdcsource模式. * 优化trycatch异常日志打印代码 * 支持sqlservercdc功能 Co-authored-by:
金鑫 <jinyanhui@huansi.net>
-
Kerwin authored
-
mengyejiang authored
* 修改点: 1、dlink-flink1.14增加postgres cdc connector,支持flinksql开发。 2、整库同步增加支持postgres数据库。 * 修改点: 1、METADATA_TYPE与dlink-meta中保持一致,避免Driver找不到lib的情况; 2、url中/后改为databasename,原来代码中填schema名是不正确的。 * postgresCDCBuilder改为首字母大写。
-
- 23 Aug, 2022 2 commits
-
-
aiwenmo authored
Co-authored-by:
wenmo <32723967+wenmo@users.noreply.github.com>
-
lnnlab authored
-
- 22 Aug, 2022 2 commits
-
-
aiwenmo authored
Co-authored-by:
wenmo <32723967+wenmo@users.noreply.github.com>
-
aiwenmo authored
* [Feature-923][*] Build column lineage base on flink logical plan * [Feature-923][*] Dynamic add getColumnOrigins method to class RelMdColumnOrigins by javassist Co-authored-by:
wenmo <32723967+wenmo@users.noreply.github.com>
-
- 21 Aug, 2022 7 commits
- 20 Aug, 2022 2 commits
-
-
aiwenmo authored
Co-authored-by:
wenmo <32723967+wenmo@users.noreply.github.com>
-
Kerwin authored
-
- 19 Aug, 2022 1 commit
-
-
aiwenmo authored
Co-authored-by:
wenmo <32723967+wenmo@users.noreply.github.com>
-
- 18 Aug, 2022 1 commit
-
-
zhu-mingye authored
-
- 17 Aug, 2022 1 commit
-
-
xiaofeng authored
Co-authored-by:
liuxiaofeng <liuxiaofeng@xcxd.com>
-
- 16 Aug, 2022 2 commits
- 15 Aug, 2022 2 commits
- 13 Aug, 2022 1 commit
-
-
Kerwin authored
-
- 12 Aug, 2022 1 commit
-
-
Kerwin authored
[Feature-868][Common] Added github workflow to check the checkstyle, test and build of each PR (#869) * Added github workflow to check the checkstyle, test and build of each PR. * Specify the checkstyle file.
-
- 11 Aug, 2022 7 commits
-
-
hzymarine authored
Co-authored-by:
hzymarine <marinehuang163@163.com>
-
第一片心意 authored
* [文档]: 1. 补充部署细节。 2. 增加一些 flink sql 案例。 * [bug修复]: 修复 yarn per job 、 batch 模式下任务完成后,yarn 不自动释放 flink JM 角色资源的问题,任务以 detached 模式运行。
-
aiwenmo authored
Co-authored-by:
wenmo <32723967+wenmo@users.noreply.github.com>
-
xiaofeng authored
Co-authored-by:
liuxiaofeng <liuxiaofeng@xcxd.com>
-
sunyanqing01 authored
-
zhonggui.wang authored
<!--新增 pulsar-client-api jar 解决找不到SubscriptionType报错--> Co-authored-by: wzh8384 <wzh615961806>
-
Kerwin authored
-
- 10 Aug, 2022 3 commits
-
-
aiwenmo authored
Co-authored-by:
wenmo <32723967+wenmo@users.noreply.github.com>
-
zhongjingq authored
* fix: MYSQL CDC JsonDebeziumDeserializationSchema 字节转字符提定字符编码 UTF-8 * fix: MYSQL CDC SQLSinkBuilder 转换mysql 类型datetime时,时区不正确,应该设置UTC实区 * [Feature]: 1:增加datastream-starrocks 实现,目前strrocks官网jar只到1.14对应的flink版本 2:增加datastream-kafka-json 实现,主要实现抽像出必须的记录数据,增加扩展op、is_delete、schemaName,tableName,ts_ms等字段,方便业务使用 * [optimization]:优化调整重复代码 [optimization]:优化调整重复代码
-
chrofram authored
change Row.withPositions() to new Row()
-