refactor

apache · Dec 12, 2024 · 5c54961 · 5c54961
1 parent 57c5685
commit 5c54961
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/...rc/main/java/org/apache/pinot/controller/helix/core/realtime/SegmentCompletionConfig.java b/...rc/main/java/org/apache/pinot/controller/helix/core/realtime/SegmentCompletionConfig.java
@@ -25,7 +25,7 @@
 
 public class SegmentCompletionConfig {
   public static final String FSM_SCHEME = "pinot.controller.segment.completion.fsm.scheme.";
-  public static final String DEFAULT_FSM_SCHEME_KEY = "pinot.controller.segment.completion.fsm.scheme.default.";
+  public static final String DEFAULT_FSM_SCHEME_KEY = "pinot.controller.segment.completion.fsm.scheme.default";
   public static final String DEFAULT_FSM_SCHEME = "default";
   private final Map<String, String> _fsmSchemes = new HashMap<>();
   private final String _defaultFsmScheme;

diff --git a/...ain/java/org/apache/pinot/controller/helix/core/realtime/SegmentCompletionFSMFactory.java b/...ain/java/org/apache/pinot/controller/helix/core/realtime/SegmentCompletionFSMFactory.java
@@ -33,13 +33,12 @@ private SegmentCompletionFSMFactory() {
 
   private static final Logger LOGGER = LoggerFactory.getLogger(SegmentCompletionFSMFactory.class);
   private static final Map<String, Class<? extends SegmentCompletionFSM>> FSM_CLASS_MAP = new HashMap<>();
-  public static final String DEFAULT = "default";
 
   // Static block to register the default FSM
   static {
     try {
       Class<?> clazz = Class.forName(BlockingSegmentCompletionFSM.class.getCanonicalName());
-      register(DEFAULT, (Class<? extends SegmentCompletionFSM>) clazz);
+      register(SegmentCompletionConfig.DEFAULT_FSM_SCHEME, (Class<? extends SegmentCompletionFSM>) clazz);
       LOGGER.info("Registered default BlockingSegmentCompletionFSM");
     } catch (Exception e) {
       LOGGER.error("Failed to register default BlockingSegmentCompletionFSM", e);