boy397 commented on issue #39135: URL: https://github.com/apache/beam/issues/39135#issuecomment-4821065885
Hi @junaiddshaukat i want to work on this issue but i have few questions : To fan out the watermark correctly, does WatermarkManager already support broadcasting the watermark to all tasks/partitions, or should we modify GroupByKeyProcessor to explicitly handle watermark propagation to downstream nodes? Should the internal repartition topic be created dynamically via the runner, or is it assumed to be managed/auto-created by Kafka Streams? could you please answer these -- 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]
