biandou1313

flinkx1.12 mysql同步hive 无法断点续传（yarn-perjob模式）

7

### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened  { "job": { "setting": { "errorLimit": {}, "speed": {...

flinkx1.12性能问题：mysql-hive 数据量9000万+

8

### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened 问题描述： 1、来源数据为700万+ 时，通过跳针flink job相关参数，可以在6分钟之内处理完 2、来源为9000万+时，mysql-hive同步时，来源端mysqlsource无法拉取数据，是因为source端需要一次查询数据 无法范围rs 来源端执行SQL: SELECT `id`, `device_id`,...

flinkx1.12性能问题：mysql-hive 如何提高离线同步效率

1

### 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...

flinkx1.12 mysql-hive同步性能问题 数据量10000万+

1

### 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...

flinkx1.12同步mysql-hive 数据量700万，本地模式可以跑，yarn-perjob无法跑

4

### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened    执行JSON: { "job": { "content": [{ "reader":...

flinkx 执行批量同步mysql-mysql, update模式：执行一直都是报错

3

BUG信息： JdbcOutputFormat [Flink_Job] writeRecord error: when converting field[0] in Row(+I(18,xulei,22,wuhan)) at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915) at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.quiesceTimeServiceAndCloseOperator(StreamOperatorWrapper.java:168) at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:131) at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:135) at org.apache.flink.streaming.runtime.tasks.OperatorChain.closeOperators(OperatorChain.java:439) at org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:627) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:589) at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:755) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:570)...

如何贡献代码

3

## Development Task 1、chunjun1.12 已经修复hive无法指定分区 2、chunjun1.12已经扩展hive读 3、chunjun1.12已经扩展robbitmq

chunjun标准模式下mysql-hive 并发执行问题

1

### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened 来源数据mysql总数据只有8300万左右 1、source端：执行并发操作，并没有按照切分键均匀查询 切分键为Id 2、hivesink端：执行期间出现两个问题：a、执行过程中移动文件出问题，比如：并发20，先执行完的通道，会将.data文件删除，后面还在执行的通道，找不到.data文件 b|、通道多了 很多通道没有数据直接关闭    ###...

chunjun执行mysql-mysql insert模式下问题

2

### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened 问题一：insert 模式下 主键重复 任务直接终止 问题二：insert模式下 配置脏数据存储 也没有用 任务终止 ，张数据表也无数据 ###...

chunjun配置指标统计输出至mysql

2

### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened 1、根据chunjun配置mysql 但是本地或者标准模式下 都无法找到mysqlreport ### What you expected to happen 1、json中配置...