SEZ9 commented on issue #12820: URL: https://github.com/apache/seatunnel/issues/12820#issuecomment-6207417140
Please link this to #12366 and confirm the routing logic there is merged (or at least stable) before building assertions on it; the test should assert the behavior the fix introduces (each fixed bucket's records handled by exactly one writer), so clarify how writer ownership will be observed in the test — e.g. via Paimon manifest/data-file metadata per bucket, sink metrics, or log inspection. Suggest adding the scenario to the existing connector-paimon-e2e module alongside current fixed-bucket cases, with bucket count >= 2 and parallelism >= 2 (ideally parallelism != bucket count to exercise uneven routing), and verifying both row count and content per bucket after the job finishes. Please run the new case multiple times on the supported Flink E2E environment to check for flakiness (parallel writers + commit ordering can be timing-sensitive), and note in the PR which Flink versions were validated. <!-- streview-comment:1794 --> -- 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]
