mxm commented on code in PR #18661:
URL: https://github.com/apache/iceberg/pull/18661#discussion_r4470462231
##########
flink/v2.3/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSinkTableMaintenance.java:
##########
@@ -436,6 +441,87 @@ public void testConvertEqualityDeletesE2e(String lockType)
throws Exception {
}
}
+ // TODO: Also run with the JDBC lock once JdbcLockFactory creates the lock
table safely. The
+ // trigger manager and the lock remover both create it on open, and the
second CREATE TABLE
+ // fails with "table already exists" when they race.
Review Comment:
Can we create an issue for that?
--
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]
