use iceberg's conf name

apache · May 28, 2024 · 61e804f · 61e804f
1 parent ef6d684
commit 61e804f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/InputFormatConfig.java b/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/InputFormatConfig.java
@@ -87,7 +87,6 @@ private InputFormatConfig() {
   public static final String CATALOG_DEFAULT_CONFIG_PREFIX = "iceberg.catalog-default.";
   public static final String QUERY_FILTERS = "iceberg.query.filters";
 
-  public static final String TABLE_PLAN_WORKER_POOL_SIZE = "iceberg.worker.num-threads";
 
   public enum InMemoryDataModel {
     PIG,

diff --git a/...erg/iceberg-handler/src/main/java/org/apache/iceberg/mr/mapreduce/IcebergInputFormat.java b/...erg/iceberg-handler/src/main/java/org/apache/iceberg/mr/mapreduce/IcebergInputFormat.java
@@ -63,6 +63,7 @@
 import org.apache.iceberg.SchemaParser;
 import org.apache.iceberg.SnapshotRef;
 import org.apache.iceberg.StructLike;
+import org.apache.iceberg.SystemConfigs;
 import org.apache.iceberg.Table;
 import org.apache.iceberg.TableProperties;
 import org.apache.iceberg.TableScan;
@@ -211,7 +212,7 @@ public List<InputSplit> getSplits(JobContext context) {
         });
     final ExecutorService workerPool =
         ThreadPools.newWorkerPool("iceberg-plan-worker-pool",
-            conf.getInt(InputFormatConfig.TABLE_PLAN_WORKER_POOL_SIZE, ThreadPools.WORKER_THREAD_POOL_SIZE));
+            conf.getInt(SystemConfigs.WORKER_THREAD_POOL_SIZE.propertyKey(), ThreadPools.WORKER_THREAD_POOL_SIZE));
     try {
       return planInputSplits(table, conf, workerPool);
     } finally {