flinksql sink to sr often fail because of nullpoint
flinksql or DS sink to starrocks often fail because of nullpoint
- flink sql 和 flink ds sink starrocks 经常报NullpointException
- 重新编译代码 并上传到flink 集群 验证，有效
flink sql 和 flink ds sink starrocks 经常报NullpointException
- 使用flink-starrocks-connector 版本: flink-connector-starrocks-1.2.6_flink-1.15.jar
翻阅StarRocksSink 源码 DefaultStreamLoader 类
解决方案： 到github 上查询目前最新的版本中对该bug 修复 下载源码查看 DefaultStreamLoader 类
重新下载源码到本地 打包后 打包后的 flink-starrocks-connector 版本: flink-connector-starrocks-1.2.7_flink-1.15.jar