imankhadiv commented on PR #29027: URL: https://github.com/apache/flink/pull/29027#issuecomment-5780047297
Sorry — fair, too much text. Short version: **Bug:** `toDataStream` on a table with a null rowtime throws NPE — `OutputConversionOperator` dereferences `getTimestamp(...)` unchecked, on both rowtime paths. **Fix:** null-check it. The null branch calls `eraseTimestamp()` rather than just skipping `setTimestamp()`, because `outRecord` is reused across records and would otherwise keep the previous record's timestamp. 19 lines of src, the rest is tests. I have also trimmed the PR description. -- 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]
