使用chunjun对接flink 1.13.6导入数据,数据没进去
source:mysql
sink:starrocks
json如下
{
"job": {
"content": [
{
"reader": {
"parameter": {
"host": "localhost",
"port": 3306,
"serverId": 1,
"databaseList": [
"test"
],
"tableList": [
"test.lineorder"
],
"username": "root",
"password": "",
"column": [
{
"name": "lo_orderkey",
"type": "int"
},
{
"name": "lo_linenumber",
"type": "int"
},
{
"name": "lo_custkey",
"type": "int"
},
{
"name": "lo_partkey",
"type": "int"
},
{
"name": "lo_suppkey",
"type": "int"
},
{
"name": "lo_orderdate",
"type": "int"
},
{
"name": "lo_orderpriority",
"type": "string"
},
{
"name": "lo_shippriority",
"type": "int"
},
{
"name": "lo_quantity",
"type": "int"
},
{
"name": "lo_extendedprice",
"type": "int"
},
{
"name": "lo_ordtotalprice",
"type": "int"
},
{
"name": "lo_discount",
"type": "int"
},
{
"name": "lo_revenue",
"type": "int"
},
{
"name": "lo_supplycost",
"type": "int"
},
{
"name": "lo_tax",
"type": "int"
},
{
"name": "lo_commitdate",
"type": "int"
},
{
"name": "lo_shipmode",
"type": "string"
}
],
"writeMode": "insert"
},
"table": {
"tableName": "lineorder"
},
"name": "mysqlcdcreader"
},
"writer": {
"parameter": {
"url": "jdbc:mysql://localhost:9232",
"feNodes": [
"*.*.*.184:8232",
"*.*.*.185:8232",
"*.*.*.186:8232"
],
"database": "wsw",
"table": "like_",
"username": "root",
"password": "",
"column": [
{
"name": "lo_orderkey",
"type": "int"
},
{
"name": "lo_linenumber",
"type": "int"
},
{
"name": "lo_custkey",
"type": "int"
},
{
"name": "lo_partkey",
"type": "int"
},
{
"name": "lo_suppkey",
"type": "int"
},
{
"name": "lo_orderdate",
"type": "int"
},
{
"name": "lo_orderpriority",
"type": "string"
},
{
"name": "lo_shippriority",
"type": "int"
},
{
"name": "lo_quantity",
"type": "int"
},
{
"name": "lo_extendedprice",
"type": "int"
},
{
"name": "lo_ordtotalprice",
"type": "int"
},
{
"name": "lo_discount",
"type": "int"
},
{
"name": "lo_revenue",
"type": "int"
},
{
"name": "lo_supplycost",
"type": "int"
},
{
"name": "lo_tax",
"type": "int"
},
{
"name": "lo_commitdate",
"type": "int"
},
{
"name": "lo_shipmode",
"type": "string"
}
]
},
"name": "starrockswriter"
}
}
],
"setting": {
"restore": {
"isRestore": false,
"isStream": true
},
"speed": {
"channel": 1
}
}
}
}
请问下是我哪里配置的不正确么?