json任务正常运行 不报错 但是没有写入数据到Oracle中(mysqlcdc到Oracle)
- Dominant language
- Java
- Stars
- 4.1k
- Forks
- 1.7k
- PR merge metrics
- No merged PRs in 30d
Description
### 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 any help.
- [ ] I had read the documentation: [ChunJun doc](https://dtstack.github.io/chunjun) but it didn't help me.
### Description
JSON脚本:
{
"job": {
"content": [
{
"reader": {
"parameter": {
"host": "172.2.0.22",
"port": 30001,
"serverId": 1,
"databaseList": [
"dps"
],
"tableList": [
"qixin_source"
],
"username": "root",
"password": "wayz@1234",
"column": [
{
"name": "id",
"type": "int"
},
{
"name": "name",
"type": "string"
},
{
"name": "gender",
"type": "int"
},
{
"name": "data",
"type": "string"
},
{
"name": "create_time",
"type": "datetime"
},
{
"name": "update_time",
"type": "datetime"
}
],
"writeMode": "update",
"updateKey": ["id"]
},
"table": {
"tableName": "qixin_source"
},
"name": "mysqlcdcreader"
},
"writer": {
"parameter": {
"username": "system",
"password": "system",
"connection": [
{
"jdbcUrl": "jdbc:oracle:thin:@//172.3.0.149:1521/helowinXDB",
"table": [
"QIXIN_SINK"
],
"schema":"BI"
}
],
"column": [
{
"name": "id",
"type": "int"
},
{
"name": "name",
"type": "VARCHAR2"
},
{
"name": "gender",
"type": "VARCHAR2"
},
{
"name": "data",
"type": "VARCHAR2"
},
{
"name": "create_time",
"type": "VARCHAR2"
},
{
"name": "update_time",
"type": "VARCHAR2"
}
],
"mode": "update"
},
"table": {
"tableName": "QIXIN_SINK"
},
"name": "oraclewriter"
},
"transformer": {
"transformSql": "select id, if(name IS NULL,'',name) as name, if(gender IS NULL,'',cast(gender as CHAR)) as gender, if(data IS NULL,'',data) as data, if(create_time IS NULL,'',cast(create_time as CHAR)) as create_time, if(update_time IS NULL,'',cast(update_time as CHAR)) as update_time from qixin_source"
}
}
],
"setting": {
"errorLimit": {
"record": 100
},
"speed": {
"bytes": 0,
"channel": 1,
"readerChannel": 1,
"writerChannel": 1
}
}
}
}
任务提交命令:sh bin/chunjun-local.sh -job json/qixin/mysql_oracle_cdc_transform.json
谢谢!!!
### Code of Conduct
- [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)
Contributor guide
Assessment
This issue has not been assessed yet.