Refactor ConfigMetaDataChangedEventHandler (#29383)

apache · Dec 13, 2023 · cd56afb · cd56afb
1 parent a5f007c
commit cd56afb
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...ata/pipeline/core/metadata/node/event/handler/impl/ConfigMetaDataChangedEventHandler.java b/...ata/pipeline/core/metadata/node/event/handler/impl/ConfigMetaDataChangedEventHandler.java
@@ -42,6 +42,7 @@ public Pattern getKeyPattern() {
         return PipelineMetaDataNode.CONFIG_PATTERN;
     }
 
+    @SuppressWarnings("unchecked")
     @Override
     public void handle(final String jobId, final DataChangedEvent event) {
         JobConfiguration jobConfig;
@@ -54,7 +55,7 @@ public void handle(final String jobId, final DataChangedEvent event) {
             return;
         }
         log.info("{} job configuration: {}, disabled={}", event.getType(), event.getKey(), jobConfig.isDisabled());
-        TypedSPILoader.findService(JobConfigurationChangedProcessor.class, PipelineJobIdUtils.parseJobType(jobConfig.getJobName()).getType()).ifPresent(
-                optional -> new JobConfigurationChangedProcessEngine().process(event.getType(), jobConfig, optional));
+        String jobType = PipelineJobIdUtils.parseJobType(jobConfig.getJobName()).getType();
+        TypedSPILoader.findService(JobConfigurationChangedProcessor.class, jobType).ifPresent(optional -> new JobConfigurationChangedProcessEngine().process(event.getType(), jobConfig, optional));
     }
 }