diff --git a/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastFitableExecutor.java b/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastFitableExecutor.java
index aa515062..ade6de21 100644
--- a/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastFitableExecutor.java
+++ b/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastFitableExecutor.java
@@ -53,7 +53,7 @@ public Object execute(Fitable fitable, List<Target> targets, InvocationContext c
                         fitable.toUniqueId());
                 return null;
             }
-        }).reduce(context.accumulator()).orElse(null);
+        }).filter(Objects::nonNull).reduce(context.accumulator()).orElse(null);
     }
 
     private Object execute(Fitable fitable, Target target, InvocationContext context, Object[] args) {
diff --git a/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastGenericableExecutor.java b/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastGenericableExecutor.java
index 974dd2e3..50f068a9 100644
--- a/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastGenericableExecutor.java
+++ b/framework/fit/java/fit-broker/src/main/java/modelengine/fitframework/broker/support/MulticastGenericableExecutor.java
@@ -13,6 +13,7 @@
 
 import java.util.Collections;
 import java.util.List;
+import java.util.Objects;
 
 /**
  * 表示 {@link GenericableExecutor} 的多播调用实现。
@@ -39,6 +40,6 @@ public Object execute(List<Fitable> fitables, InvocationContext context, Object[
                         fitable.toUniqueId());
                 return null;
             }
-        }).reduce(context.accumulator()).orElse(null);
+        }).filter(Objects::nonNull).reduce(context.accumulator()).orElse(null);
     }
 }