??????
??????????????2021??????????????????????flinkx??????????????????????????????????????????????????????????????????
????flnkx??????????json????????????????????????????????????????????????????????????begin1??????end1????????begin2??reader??end2??writer??
????????????????????
{
"job": {
"content": [
{
"reader": {
"parameter": {
"username": "root",
"password": "123456",
"connection": [{
"jdbcUrl":
["jdbc:mysql://localhost:3306/flinkx1?useUnicode=true&characterEncoding=utf8"],
"table": ["begin1","begin2"]
}],
"column": [
{
"name": "id",
"type": "int"
},
{
"name": "name",
"type": "varchar"
}
],
"customSql": "",
"splitPk": "id",
"queryTimeOut": 1000,
"requestAccumulatorInterval": 2,
"increColumn": "id",
"startLocation": ""
},
"name": "mysqlreader"
},
"writer": {
"name": "mysqlwriter",
"parameter": {
"username": "root",
"password": "123456",
"connection": [
{
"jdbcUrl":
"jdbc:mysql://localhost:3306/flinkx1?useUnicode=true&characterEncoding=utf8",
"table": ["end1","end2"]
}
],
"writeMode": "insert",
"column": [
{
"name": "id",
"type": "int"
},
{
"name": "name",
"type": "varchar"
}
],
"batchSize": 1024
}
}
}
],
"setting": {
"speed": {
"channel": 2,
"bytes": 1000
},
"errorLimit": {
"record": 0
},
"restore": {
"maxRowNumForCheckpoint": 0,
"isRestore": false,
"restoreColumnName": "",
"restoreColumnIndex": 0
},
"log" : {
"isLogger": false,
"level" : "debug",
"path" : " /data/flinkx/flinkxconf/log/",
"pattern":""
}
}
}
}
