wombatu-kun commented on PR #19018: URL: https://github.com/apache/hudi/pull/19018#issuecomment-5112211844
Added `TestHoodieSinkTask`, which pins the index to `transactionParticipants` across open, close and stop. It asserts on two levels: structurally, flattening the index back to `TopicPartition` keys must reproduce the primary map exactly with no empty per-topic buckets left behind, and behaviorally, records pushed through `put()` must reach the participant the primary map holds. The coordinator partition is covered as well, since `close()` takes a separate branch for it. -- 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]
