pvary commented on code in PR #12979:
URL: https://github.com/apache/iceberg/pull/12979#discussion_r2104171688
##########
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/TableMaintenance.java:
##########
@@ -59,6 +59,12 @@ public class TableMaintenance {
static final String FILTER_OPERATOR_NAME_PREFIX = "Filter ";
static final String LOCK_REMOVER_OPERATOR_NAME = "Lock remover";
+ static final long RATE_LIMIT_SECOND_DEFAULT = 60;
+ static final long LOCK_CHECK_DELAY_SECOND_DEFAULT = 30;
+ static final int MAX_READ_BACK_DEFAULT = 100;
+ static final int PARALLELISM_DEFAULT = ExecutionConfig.PARALLELISM_DEFAULT;
+ static final String SLOT_SHARING_GROUP_DEFAULT =
StreamGraphGenerator.DEFAULT_SLOT_SHARING_GROUP;
Review Comment:
Renaming constants is a big strange to me
--
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: issues-unsubscr...@iceberg.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For additional commands, e-mail: issues-h...@iceberg.apache.org
