DanielLeens commented on PR #10890: URL: https://github.com/apache/seatunnel/pull/10890#issuecomment-4488784092
Thanks for clarifying this. I agree that the shared Flink schema-evolution changes are also being worked in [#10648](https://github.com/apache/seatunnel/pull/10648), and I should have said that dependency more explicitly. The reason I still treated it as a blocker on this PR is that the current head of `#10890` still carries those shared-layer changes in the actual diff and runtime path. On the latest head here, `BroadcastSchemaSinkOperator` still advances `lastProcessedEpoch` before the sink-side `applySchemaChange(...)` completion boundary, so from a merge-decision perspective I still cannot clear that path yet. If your plan is to drop that carried shared change once `#10648` lands, or to rework it directly in this PR, please push that as a new commit and I will gladly re-review the latest head. -- 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]
