shunping opened a new pull request, #36983: URL: https://github.com/apache/beam/pull/36983
This PR mainly fixes the "zero key length" panic occurred in our tests. - First, it fixes the preprocessing of TestStream to preserve KV coder. This is necessary for the next step to retrieve key coder. - Second, it applies the same approach as #36927 to obtain key coder and add keyBytes when constructing pending elements in TestStream In addition, it shows a concerning situation that panics in watermark eval loop does not trigger a pipeline failure. To fix that, we change the order of two `defer` calls, so that the panic is handled before a premature channel closing. -- 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]
