chunjun
chunjun copied to clipboard
DTStack
A data integration framework
## Purpose of this pull request ## Which issue you fix Fixes #1886 ## Checklist: - [x] I have executed the **'mvn spotless:apply'** command to format my code. - [...
### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar feature requirement. ### Description sql模式下新增特性： 1、写入时支持配置rowkeyExpress 2、写入时支持配置hbase的时间戳，支持选项：当前时间（默认）、指定时间列名（例如：列簇:字段名）、指定具体时间 3、读取时支持配置客户端每次 rpc 从服务器端读取的列数，默认不限制。 4、读取时支持配置 rowKey起始点、rowKey结束点、rowkey是否是BytesBinary 5、解决sql模式下缺少Hbase2DynamicTableFactory 6、hbase...
### 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...
## Purpose of this pull request ## Which issue you fix Fixes # (issue). ## Checklist: - [x] I have executed the **'mvn spotless:apply'** command to format my code. -...
## Purpose of this pull request ## Which issue you fix Fixes #1904 ## Checklist: - [x] I have executed the **'mvn spotless:apply'** command to format my code. - [...
### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened 在 yarn-pre-job 模式找不到 sqlserver 相关驱动 ``` java.lang.RuntimeException: java.sql.SQLException: No suitable...
### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened MySQL读取200W数据写入iceberg累加器numRead和numWrite都为200w，iceberg实际查询只有60W ### What you expected to happen MySQL读取200W数据写入iceberg累加器numRead和numWrite都为200w，iceberg实际查询只有60W ### How...
… and when the source sends it downstream #1901 ## Purpose of this pull request ## Which issue you fix Fixes # (issue). ## Checklist: - [ ] I have...
### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar feature requirement. ### Description _No response_ ### Use case _No response_ ### Related issues...
### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar feature requirement. ### Description When submitting a Flink job, all the JARs under the...