问答 使用chunjun对接flink 1.13.6导入数据,数据没进去

使用chunjun对接flink 1.13.6导入数据,数据没进去

   wsw    发布于 2022-11-16 11:35  316  0

使用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
}
}
}
}

请问下是我哪里配置的不正确么?

0条回答
社区公告
  • 大数据领域最专业的产品&技术交流社区,专注于探讨与分享大数据领域有趣又火热的信息,专业又专注的数据人园地

最新活动更多
微信扫码获取数字化转型资料
钉钉扫码加入技术交流群