fix: 改进 Fork.join() null 数据处理逻辑

修复问题：之前的修复在检测到 null 数据且是最后一个分支时会返回已有数据，
导致聚合提前完成，丢失分支数据。

改进策略：当 inputData 为 null 时，不更新分支计数，直接返回 null，
等待正确的数据到来后正常完成聚合。

这样可以避免因竞态条件导致的数据丢失问题。

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: CodeCasterX

framework/waterflow/java/waterflow-core/src/main/java/modelengine/fit/waterflow/domain/states/Fork.java

@@ -99,19 +99,14 @@ public synchronized R process(FlowContext<O> input) {
 
                 // Issue #247: 智能处理并发场景下的 null 数据
                 // 在某些竞态条件下，FlowContext.data 可能为 null
+                // 此时不更新分支计数，等待正确的数据到来
                 O inputData = input.getData();
                 if (inputData == null) {
-                    LOG.warn("[Fork.join] Received null FlowContext.data. "
+                    LOG.warn("[Fork.join] Received null FlowContext.data, skipping. "
                             + "key={}, session={}, thread={}, branch={}/{}, acc={}",
                             key, input.getSession().getId(), Thread.currentThread().getName(),
                             acc.second() + 1, forkNumber.get(), acc.first());
-
-                    // 跳过此分支，不更新累加器
-                    // 如果是最后一个分支，返回已有数据（避免整个流程失败）
-                    if (acc.second() + 1 == forkNumber.get()) {
-                        accs.remove(key);
-                        return acc.first();
-                    }
+                    // 返回 null 表示聚合未完成，等待有效数据
                     return null;
                 }