(gravitino) branch branch-1.2 updated: [Cherry-pick to branch-1.2] [#10311] fix(optimizer): resolve built-in rewrite adapter by template name (#10307) (#10312)

[diqiu50]

This is an automated email from the ASF dual-hosted git repository.

diqiu50 pushed a commit to branch branch-1.2
in repository https://gitbox.apache.org/repos/asf/gravitino.git


The following commit(s) were added to refs/heads/branch-1.2 by this push:
     new 34dd5799ee [Cherry-pick to branch-1.2] [#10311] fix(optimizer): 
resolve built-in rewrite adapter by template name (#10307) (#10312)
34dd5799ee is described below

commit 34dd5799ee12abf70b6a8d2b619f66939e824f4a
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Mar 9 20:52:52 2026 +0800

    [Cherry-pick to branch-1.2] [#10311] fix(optimizer): resolve built-in 
rewrite adapter by template name (#10307) (#10312)
    
    **Cherry-pick Information:**
    - Original commit: 1ad5c69e52b9103ba8311881802bff526873475b
    - Target branch: `branch-1.2`
    - Status: ✅ Clean cherry-pick (no conflicts)
    
    Co-authored-by: FANNG <xiaoj...@datastrato.com>
---
 .../optimizer/recommender/job/GravitinoJobSubmitter.java           | 6 ++++--
 .../optimizer/recommender/job/TestGravitinoJobSubmitter.java       | 7 ++++---
 2 files changed, 8 insertions(+), 5 deletions(-)

diff --git 
a/maintenance/optimizer/src/main/java/org/apache/gravitino/maintenance/optimizer/recommender/job/GravitinoJobSubmitter.java
 
b/maintenance/optimizer/src/main/java/org/apache/gravitino/maintenance/optimizer/recommender/job/GravitinoJobSubmitter.java
index 07ee840ed4..a6b9362c80 100644
--- 
a/maintenance/optimizer/src/main/java/org/apache/gravitino/maintenance/optimizer/recommender/job/GravitinoJobSubmitter.java
+++ 
b/maintenance/optimizer/src/main/java/org/apache/gravitino/maintenance/optimizer/recommender/job/GravitinoJobSubmitter.java
@@ -30,7 +30,7 @@ import 
org.apache.gravitino.maintenance.optimizer.api.recommender.JobSubmitter;
 import org.apache.gravitino.maintenance.optimizer.common.OptimizerEnv;
 import org.apache.gravitino.maintenance.optimizer.common.conf.OptimizerConfig;
 import 
org.apache.gravitino.maintenance.optimizer.common.util.GravitinoClientUtils;
-import 
org.apache.gravitino.maintenance.optimizer.recommender.handler.compaction.CompactionStrategyHandler;
+import org.apache.gravitino.policy.IcebergDataCompactionContent;
 
 /** Submits optimizer jobs to Gravitino using job template adapters. */
 public class GravitinoJobSubmitter implements JobSubmitter {
@@ -47,7 +47,9 @@ public class GravitinoJobSubmitter implements JobSubmitter {
    * @return provider name
    */
   private final Map<String, Class<? extends GravitinoJobAdapter>> jobAdapters =
-      ImmutableMap.of(CompactionStrategyHandler.NAME, 
GravitinoCompactionJobAdapter.class);
+      ImmutableMap.of(
+          IcebergDataCompactionContent.JOB_TEMPLATE_NAME_VALUE,
+          GravitinoCompactionJobAdapter.class);
 
   @Override
   public String name() {
diff --git 
a/maintenance/optimizer/src/test/java/org/apache/gravitino/maintenance/optimizer/recommender/job/TestGravitinoJobSubmitter.java
 
b/maintenance/optimizer/src/test/java/org/apache/gravitino/maintenance/optimizer/recommender/job/TestGravitinoJobSubmitter.java
index 621f41f7d5..68f79671c4 100644
--- 
a/maintenance/optimizer/src/test/java/org/apache/gravitino/maintenance/optimizer/recommender/job/TestGravitinoJobSubmitter.java
+++ 
b/maintenance/optimizer/src/test/java/org/apache/gravitino/maintenance/optimizer/recommender/job/TestGravitinoJobSubmitter.java
@@ -24,15 +24,16 @@ import org.apache.gravitino.NameIdentifier;
 import 
org.apache.gravitino.maintenance.optimizer.api.recommender.JobExecutionContext;
 import org.apache.gravitino.maintenance.optimizer.common.OptimizerEnv;
 import org.apache.gravitino.maintenance.optimizer.common.conf.OptimizerConfig;
-import 
org.apache.gravitino.maintenance.optimizer.recommender.handler.compaction.CompactionStrategyHandler;
+import org.apache.gravitino.policy.IcebergDataCompactionContent;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 
 public class TestGravitinoJobSubmitter {
   @Test
-  void loadJobAdapterReturnsCompactionAdapter() {
+  void loadJobAdapterReturnsCompactionAdapterForBuiltInTemplateName() {
     GravitinoJobSubmitter submitter = new GravitinoJobSubmitter();
-    GravitinoJobAdapter adapter = 
submitter.loadJobAdapter(CompactionStrategyHandler.NAME);
+    GravitinoJobAdapter adapter =
+        
submitter.loadJobAdapter(IcebergDataCompactionContent.JOB_TEMPLATE_NAME_VALUE);
     Assertions.assertTrue(adapter instanceof GravitinoCompactionJobAdapter);
   }