chunjun

chunjun copied to clipboard

hbase->hbase的数据同步增加transformsql配置之后报错

2

### Search before asking - [ ] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar question. - [ ] I had googled my question but i didn't get...

wuyiccc

flinkx-connector-kafka 编译缺少 com.pingcap.ticdc.cdc:ticdc-decoder:jar:5.2.0-SNAPSHOT

14

flinkx-connector-kafka: Could not resolve dependencies for project com.dtstack.flinkx:flinkx-connector-kafka:jar:1.12-SNAPSHOT: Failure to find com.pingcap.ticdc.cdc:ticdc-decoder:jar:5.2.0-SNAPSHOT in https://github.com/dtstack/maven-repository/raw/master/ was cached in the local repository, resolution will not be reattempted until the update interval of...

qiaoqw

1.11版本 hdfs->mysql flink web ui 无日志

3

mztt-elfine

source(oracle)->sink(greenplum)时，mode:insert正常同步数据，mode(update)提示报错postgresql版本要>=9.5

1

### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened 0，环境： chunjun版本：v1.12.5（2022-07-25发布的） source(oracle 12c)-->sink(greenplum 6.16.0，对应postgresql 9.4.24) 1，问题： json：mode insert时，正常同步数据；update模式时，报错： Caused...

ccchen2016

mysql轮询读取数据时，第一个切片的InputFormat中会重复读取数据

1

**Describe the bug** 当source或reader并行度>1，轮询读取数据时(例如：MySQL)，第一个切片的InputFormat中会重复读取数据。 **Screenshots** Chunjun Master分支代码中当source或reader并行度>1，轮询读取数据（例如：MySQL）时，会出现数据重复读取的情况。例如：设置mysql source的并行度为2时，mysql指定表此时只有2条数据，但是在Flink web UI中可以很明显的看见数据读取量不正确，经控制台打印分析，只有第一个子任务会重复读取数据：   

HFurther

Where can I download chunjun-dist of Flink1.14

3

### Search before asking - [x] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar question. - [x] I had googled my question but i didn't get any help....

zhilinli123

mysql binlog实时同步增量数据到clickhouse时，ClickhouseOutputFormat - Writing records failed

3

**Describe the bug** 背景： 测试使用binlog-x插件读取数据源端Mysql数据表中数据，获取mysql实时增量数据，同步写入Sink目标端Clickhouse中。 执行脚本如下： ${CHUNJUN_HOME}/bin/start-chunjun -mode local -jobType sync -job /xxx_job.json -chunjunDistDir ${CHUNJUN_HOME}/ xxx_job.json内容具体如下： { "job" : { "content" : [ { "reader" : { "parameter" : {...

berg-xu

当实现增量实时数据Sink到Clickhouse中时，根据rowKind类型值执行相关语义操作， 而clickhouse的 DELETE 与UPDATE_BEFORE 具体实现代码为空。 因此当执行数据更新操作时，将update拆分成update_before 和update_after，对于update_before则采用delete，update_after则采用insert。 ## Which issue you fix [issue 1037](https://github.com/DTStack/chunjun/issues/1037)

berg-xu

源表字段是DATE类型，目标表字段是TEXT，不会报错，但不会同步数据

1

### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar question. - [ ] I had googled my question but i didn't get any...

ccchen2016

[Bug] [SqlserverDynamicTableFactory.java ] there is a bug in getDialect function, this function will init driver with Microsoft JDBC driver.

2

### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened I am using sql job to get data from sqlserver....

yanqiw