StarRocks / starrocks

The world's fastest open query engine for sub-second analytics both on and off the data lakehouse. With the flexibility to support nearly any scenario, StarRocks provides best-in-class performance for multi-dimensional analytics, real-time analytics, and ad-hoc queries. A Linux Foundation project.
https://starrocks.io
Apache License 2.0
8.99k stars 1.81k forks source link

在flink的流式使用的时候报错 NULL value in non-nullable column #41994

Closed damokelis closed 2 months ago

damokelis commented 8 months ago

我已经使用flink-cdc写入数据到paimon中,当我从paimon的原始表中清洗完之后还是放入paimon中,就是piamon-ods到paimon-dw。然后使用flink-sql到sr中,我从来ods使用flink-sql清洗到sr中,或者是直接paimon-dw层中flink-sql到sr,都会出现NULL value in non-nullable column,字段为null值,但是这个null值是操作数据,为什么在paimon或者直接在mysql中是可以写入的呢?就算我是定义主键了。其他报错的话也就是不插入该条数据,sr是一直报错,跳过此条数据。

github-actions[bot] commented 2 months ago

We have marked this issue as stale because it has been inactive for 6 months. If this issue is still relevant, removing the stale label or adding a comment will keep it active. Otherwise, we'll close it in 10 days to keep the issue queue tidy. Thank you for your contribution to StarRocks!