m-trieu commented on code in PR #32793: URL: https://github.com/apache/beam/pull/32793#discussion_r1803752694
########## CHANGES.md: ########## @@ -151,6 +151,7 @@ * The beam interactive runner does not correctly run on flink ([#31168](https://github.com/apache/beam/issues/31168)). * When using the Flink runner from Python, 1.17 is not supported and 1.12/13 do not work correctly. Support for 1.17 will be added in 2.57.0, and the ability to choose 1.12/13 will be cleaned up and fully removed in 2.57.0 as well ([#31168](https://github.com/apache/beam/issues/31168)). +* Some streaming pipeline's coder may throw and surface a NullPointerException ([#32566](https://github.com/apache/beam/pull/32566)). Review Comment: How about: For streaming pipelines, exceptions thrown by KeyCoders may be followed by a NullPointerException. ~~I think it's the keycoder can you verify?~~ It's the KeyCoder https://github.com/apache/beam/blob/master/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/processing/StreamingWorkScheduler.java#L367-L368 -- 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]
