CosmosNi commented on code in PR #11103:
URL: https://github.com/apache/seatunnel/pull/11103#discussion_r3426530301
##########
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractWriteStrategy.java:
##########
@@ -191,7 +191,7 @@ public void setCatalogTable(CatalogTable catalogTable) {
// ── Schema Evolution
──────────────────────────────────────────────────────────
@Override
- public void applySchemaChange(SchemaChangeEvent event) throws IOException {
+ public synchronized void applySchemaChange(SchemaChangeEvent event) throws
IOException {
Review Comment:
Recommend fixing this at the MultiTableSinkWriter level rather than
per-connector,Writing needs to be suspended when performing a checkpoint.
Otherwise the same race persists for all multi-table sinks,such as StarRocks.
--
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]
