Update amoro-ams/src/main/java/org/apache/amoro/server/table/DefaultTableRuntime.java

majin1102 · sqd · web-flow · commit ecd23ac4152c · 2025-05-15T15:04:31.000+08:00
Co-authored-by: Han You &lt;hanyourmd@gmail.com&gt;
diff --git a/amoro-ams/src/main/java/org/apache/amoro/server/table/DefaultTableRuntime.java b/amoro-ams/src/main/java/org/apache/amoro/server/table/DefaultTableRuntime.java
@@ -100,7 +100,7 @@ public AmoroProcess<? extends TableProcessState> trigger(Action action) {
   @Override
   public void install(Action action, ProcessFactory<? extends TableProcessState> processFactory) {
     if (processContainerMap.putIfAbsent(action, new TableProcessContainer(processFactory))
-        == null) {
+        != null) {
       throw new IllegalStateException("ProcessFactory for action " + action + " already exists");
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -100,7 +100,7 @@ public AmoroProcess<? extends TableProcessState> trigger(Action action) {`
`100`	`100`	`@Override`
`101`	`101`	`public void install(Action action, ProcessFactory<? extends TableProcessState> processFactory) {`
`102`	`102`	`if (processContainerMap.putIfAbsent(action, new TableProcessContainer(processFactory))`
`103`		`- == null) {`
	`103`	`+ != null) {`
`104`	`104`	`throw new IllegalStateException("ProcessFactory for action " + action + " already exists");`
`105`	`105`	`}`
`106`	`106`	`}`