flink 1.13.5 写 starrocks 2.3 报问题

com.starrocks.data.load.stream.exception.StreamLoadFailException: { "TxnId": 142822546, "Label": "d6d7d3ab-53d5-4a43-924c-430b71414a40", "Status": "Fail", "Message": "all partitions have no load data", "NumberTotalRows": 0, "NumberLoadedRows": 0, "NumberFilteredRows": 0, "NumberUnselectedRows": 0, "LoadBytes": 70, "LoadTimeMs": 31262, "BeginTxnTimeMs": 1, "StreamLoadPutTimeMs": 3, "ReadDataTimeMs": 0, "WriteDataTimeMs": 13, "CommitAndPublishTimeMs": 0 }

但是表里的分区存在

改 flink-connector-starrocks 版本 从 1.2.5_flink-1.13_2.11 改成1.2.1_flink-1.13_2.11

  <dependency><groupId>com.starrocks</groupId><artifactId>flink-connector-starrocks</artifactId><version>1.2.1_flink-1.13_2.11</version><!-- <version>1.2.5_flink-1.13_2.11</version>--><exclusions><exclusion><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId></exclusion></exclusions></dependency><dependency><groupId>org.apache.flink</groupId><artifactId>flink-table_2.11</artifactId><version>1.5.0</version><exclusions><exclusion><artifactId>force-shading</artifactId><groupId>org.apache.flink</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.flink</groupId><artifactId>flink-table-api-java</artifactId><version>1.13.5</version></dependency>
</dependencies>

相关url:



flink cdc写入starrocks报错 - 💬 StarRocks 用户问答 - StarRocks中文社区论坛

flink cdc写入starrocks报错 - 💬 StarRocks 用户问答 - StarRocks中文社区论坛