【详述】Reason: column count mismatch
【背景】flink 1.13
【StarRocks版本】例如：1.19.2
// 创建目标表
String write_tb_sql = “CREATE TABLE tb (\n” +
" sso_merchant_id INT,\n" +
" tag_id BIGINT,\n" +
" tag_group_id BIGINT,\n" +
" enterprise_id INT,\n" +
" external_tag_id STRING,\n" +
" tag_name STRING,\n" +
" sort_no BIGINT,\n" +
" wechat_create_time STRING,\n" +
" create_time STRING,\n" +
" create_user STRING,\n" +
" create_user_id BIGINT,\n" +
" update_time STRING,\n" +
" update_user STRING,\n" +
" update_user_id BIGINT,\n" +
" status INT,\n" +
" tag_type INT,\n" +
" source_id STRING,\n" +
" source_type INT,\n" +
" PRIMARY KEY (sso_merchant_id,tag_id,tag_group_id) NOT ENFORCED\n" +
“) WITH (\n” +
" ‘connector’=‘starrocks’,\n" +
" ‘load-url’=‘xxx’,\n" +
" ‘jdbc-url’=‘xxx’,\n" +
" ‘username’=‘xxx’,\n" +
" ‘password’=‘xxx’,\n" +
" ‘database-name’=‘xxx’,\n" +
" ‘table-name’=‘tb’,\n" +
" ‘sink.buffer-flush.max-rows’ = ‘1000000’,\n" +
" ‘sink.buffer-flush.max-bytes’ = ‘300000000’,\n" +
" ‘sink.buffer-flush.interval-ms’ = ‘5000’,\n" +
" ‘sink.properties.column_separator’ = ‘\x01’,\n" +
" ‘sink.properties.row_delimiter’ = ‘\x02’,\n" +
" ‘sink.max-retries’ = ‘3’,\n" +
" ‘sink.properties.columns’ = ‘sso_merchant_id,tag_id,tag_group_id,enterprise_id,external_tag_id,tag_name,sort_no,wechat_create_time,create_time,create_user,create_user_id,update_time,update_user,update_user_id,status,tag_type,source_id,source_type’" +
“)”;
{“streamLoadErrorLog”:“Reason: column count mismatch, expect=18 real=19. src line: [100102917\u000137978\u00014474\u00010\u0001etJtZvEQAAra92MYJSKZIDXUL8pboOuA\u0001一般\u00010\u00012021-12-13 11:53:22\u00012021-12-15 14:14:08\u0001SynchCorpTags1\u00010\u00012021-12-15 14:14:08\u0001SynchCorpTags1\u00010\u00012\u00010\u0001\N\u00010\u00010]; \n”}
±—±-------------------------------±----------------±---------------------±---------------------±--------------±-------------------------------±-------------------------------±---------------------±-------------------------------±-------------------------------±-------------------------------±---------------------±-------------------------------±-------------------------------±---------------------±------------±------------±-------------------------------±------------+
| op | table | sso_merchant_id | tag_id | tag_group_id | enterprise_id | external_tag_id | tag_name | sort_no | wechat_create_time | create_time | create_user | create_user_id | update_time | update_user | update_user_id | status | tag_type | source_id | source_type |
±—±-------------------------------±----------------±---------------------±---------------------±--------------±-------------------------------±-------------------------------±---------------------±-------------------------------±-------------------------------±-------------------------------±---------------------±-------------------------------±-------------------------------±---------------------±------------±------------±-------------------------------±------------+
| +I | ew_enterprise_tag | 100102917 | 37978 | 4474 | 0 | etJtZvEQAAra92MYJSKZIDXUL8p… | 一般 | 0 | 2021-12-13 11:53:22 | 2021-12-15 14:14:08 | SynchCorpTags1 | 0 | 2021-12-15 14:14:08 | SynchCorpTags1 | 0 | 2 | 0 | (NULL) | 0 |
很奇怪的是在最后加多了一个 \u00010 ，我数了很多遍的列数，以及对比过输出结果，也不存在多一列，感谢解答。