kkdoon commented on issue #28554: URL: https://github.com/apache/beam/issues/28554#issuecomment-1731750827
My job only has 1 DoFn using the `@RequiresStableInput` annotation (at the terminal node). Job graph looks as follows: `KafkaIO -> DoFn -> DoFn with RequiresStableInput` The job always fails during the final savepoint operation with the watermark hold error and not after the savepoint is taken (fails between step b and c). -- 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]
