DanielLeens commented on issue #9849: URL: https://github.com/apache/seatunnel/issues/9849#issuecomment-4686421082
I traced the Cassandra source conversion path here, and this does look like a real bug. The failure is consistent with the current implementation in `TypeConvertUtil.buildSeaTunnelRow(...)`: for `TIMESTAMP` columns it calls `row.getInstant(i)` and immediately wraps it with `Objects.requireNonNull(...)`. That means a nullable Cassandra timestamp field will raise a `NullPointerException` before the row can be emitted, even though `null` should be a valid value on the normal read path. So the issue is not in your Doris sink config. The problematic path is already triggered on the Cassandra source side when a timestamp column contains `null`. Since you marked that you are willing to submit a PR, I have assigned this issue to you for follow-up. A minimal fix would likely be to make the Cassandra timestamp conversion null-safe and keep `null` as `null` instead of forcing `requireNonNull` there. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
