chunjun
chunjun copied to clipboard
A data integration framework
## Purpose of this pull request Split BigDecimalColumn into ShortColumn, IntColumn, LongColumn, FloatColumn, and DoubleColumn - Corrected some incorrect type mappings - Optimized part of the serialization code ## Which...
### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened [Bug] [oracle logminer] oracle logminer 不支持 float、timestamp、blob、clob 、decimal、number、text数据类型 ### What...
### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened binlog2mysql报IndexOutOfBoundsException错误,debug发现: dynamicPreparedStmt.getColumnNameList()方法添加的ColumnNameList元素不是表的字段,只有before和after两个无关的属性 , 导致在dynamicPreparedStmt.getColumnMeta()中此段逻辑报错(before和after不是目标表的字段,获取的index为-1,报IndexOutOfBoundsException异常) for (String columnName : columnNameList) {...
### 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....
### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened sqlserver sink conncetor 不支持text类型 ### What you expected to happen...
### Search before asking - [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues. ### What happened sqlserver cdc connector 不支持text、decimal、float、timestamp数据类型 导致任务启动失败或者数据同步丢失 ### What you expected to...
## Purpose of this pull request Chunjun core exclude all guava package, and shade rename guava cause standalone mode NoDefClassFound. ## Which issue you fix Fixes # (1147). ## Checklist:...
1.Logminer 新增 根据主键同步删除功能 但是 主键类型 目前不支持 Date 类型 需扩展PreparedStmtProxy#convertColumnRowData 方法 去进行更多的类型匹配 2. Logminer + Oracle。Date 类型数据 精准到秒
Dev main
fix some bugs
现在flink 1.14已经发布,master分支依赖的flink还是1.12.5, 有必要升级master分支依赖的flink版本到1.13.1