chunjun: [Bug][chunjun-connection-oraclelogminer] oraclelogminer to mysql have error java.lang.Long cannot be cast to java.lang.Integer
Search before asking
- I had searched in the 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?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project’s Code of Conduct
About this issue
- Original URL
- State: open
- Created a year ago
- Reactions: 1
- Comments: 33 (14 by maintainers)
感谢，我可以跑成功数据还原的功能了。贴一个示例json
{ “job”: { “content”: [ { “nameMapping”:{ “identifierMappings”:{ “test.source”:“TEST.SOURCE1” }, “casing”:“UPPER” }, “reader”: { “parameter”: { “schema”: “test”, “username”: “root”, “password”: “Pwd@1234_Cmict”, “cat”: “insert,delete,update”, “jdbcUrl”: “jdbc:mysql://10.136.106.163:33062/test?useSSL=false”, “host”: “10.136.106.163”, “port”: 33062, “table”: [ “source” ], “ddlSkip”: false, “split”: true, “pavingData”: false }, “name”: “binlogreader” }, “writer”: { “parameter”: { “connection”: [ { “jdbcUrl”: “jdbc:oracle:thin:@10.136.106.163:1521/helowin”, “table”: [ “*” ] } ], “writeMode”: “insert”, “username”: “test”, “password”: “System_$1234#_Cmict”, “batchSize”: 1, “flushIntervalMills”: 1000, “executeDdlAble”: true }, “name”: “oraclewriter” }, “restoration”: { “skipDDL”: false, “ddl”: { “type”: “mysql”, “properties”: { “database”: “chunjun”, “table”: “ddl_change”, “url”: “jdbc:mysql://localhost:3306/chunjun?useSSL=false&serverTimezone=Asia/Shanghai”, “username”: “root”, “password”: “Passw0rd” } }, “cache”: { “type”: “mysql”, “properties”: { “database”: “chunjun”, “table”: “transaction_data”, “url”: “jdbc:mysql://localhost:3306/chunjun?useSSL=false&serverTimezone=Asia/Shanghai”, “username”: “root”, “password”: “Passw0rd” } } } } ], “setting”: { “speed”: { “bytes”: 0, “channel”: 1 } } } }