swapna267 commented on PR #14063: URL: https://github.com/apache/iceberg/pull/14063#issuecomment-3288354064
Adding some more context on the root cause. FlinkSink doesn't set any UID by default.Then Flink generate an auto UID for those operators. IcebergSink is defaulting to UUID based on tablename. [Code](https://github.com/apache/iceberg/blob/main/flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java#L694). So this leads to name collision incase there are 2 parallel DAG's writing to same Iceberg table from different sources in SQL. -- 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
