DTStack / DTStack/chunjun

[Bug][chunjun-connection-oraclelogminer] oraclelogminer to mysql have error java.lang.Long cannot be cast to java.lang.Integer

Open
#1,642 33 comments 1 reaction 1 assignee Claimed by @Paddy0523 View on GitHub
bug
Dominant language
Java
Stars
4.1k
Forks
1.7k
PR merge metrics
No merged PRs in 30d

Description

### Search before asking

- [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues.

### What happened

oracle to mysql real-time sync error: java.lang.Long cannot be cast to java.lang.Integer

### What you expected to happen

sync success

### How to reproduce

oracle ddl :
CREATE TABLE "TEST"."SOURCE1" (
"ID" NUMBER NOT NULL,
"NAME" VARCHAR2(30 BYTE),
"AGG" NUMBER
)
TABLESPACE "USERS"
LOGGING
NOCOMPRESS
PCTFREE 10
INITRANS 1
STORAGE (
INITIAL 65536
NEXT 1048576
MINEXTENTS 1
MAXEXTENTS 2147483645
BUFFER_POOL DEFAULT
)
PARALLEL 1
NOCACHE
DISABLE ROW MOVEMENT
;
mysql ddl:
CREATE TABLE `taier_update_incre2_copy` (
`id` int(11) NOT NULL,
`name` varchar(255) DEFAULT NULL,
`age` int(11) DEFAULT NULL,
`record_time` datetime DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 ROW_FORMAT=DYNAMIC;

job json:
{
"job":{
"content":[
{
"reader":{
"parameter":{
"password":"System_$1234#_Cmict",
"splitUpdate":true,
"cat":"update,insert,delete",
"jdbcUrl":"jdbc:oracle:thin:@//10.136.106.163:1521/helowin",
"column":[
{
"name":"NAME",
"type":"VARCHAR2"
},
{
"name":"ID",
"type":"NUMBER"
},
{
"name":"AGG",
"type":"NUMBER"
}
],
"readPosition":"time",
"startTime": 1682038755563,
"pavingData": false,
"table":[
"TEST.SOURCE1"
],
"username":"test"
},
"name":"oraclelogminerreader",
"table":{
"tableName":"sourceTable"
}
},
"transformer":{
"transformSql":"SELECT `NAME`,`ID`,`AGG` FROM sourceTable"
},
"writer":{
"parameter":{
"password":"bigdata123",
"column":[
{
"index":0,
"name":"name",
"type":"VARCHAR"
},
{
"index":1,
"name":"id",
"type":"INT"
},
{
"index":2,
"name":"age",
"type":"INT"
}
],
"connection":[
{
"schema":"test",
"jdbcUrl":"jdbc:mysql://10.136.106.197:3306/test",
"table":[
"taier_update_incre2_copy"
]
}
],
"writeMode":"insert",
"username":"root"
},
"name":"mysqlwriter",
"flushIntervalMills":1,
"batchSize":1,
"table":{
"tableName":"sinkTable"
}
}
}
],
"setting":{
"restore":{
"isStream":true,
"isRestore":true
},
"log":{
"path":"",
"level":"debug",
"pattern":"",
"isLogger":false
},
"errorLimit":{

},
"speed":{
"readerChannel":1,
"writerChannel":1,
"bytes":0
}
}
}
}

### Anything else

_No response_

### Version

1.12_release

### Are you willing to submit PR?

- [X] Yes I am willing to submit a PR!

### Code of Conduct

- [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.