fix: 修复 Fork.java 的类型转换编译错误

CodeCasterX · CodeCasterX · commit c14bdaaadc66 · 2025-12-28T17:58:19.000+08:00
将 inputData 的类型从 Object 改为泛型 O，
以匹配 processor.process() 的参数类型要求。
diff --git a/framework/waterflow/java/waterflow-core/src/main/java/modelengine/fit/waterflow/domain/states/Fork.java b/framework/waterflow/java/waterflow-core/src/main/java/modelengine/fit/waterflow/domain/states/Fork.java
@@ -95,7 +95,7 @@ public synchronized R process(FlowContext<O> input) {
                 }
 
                 // === DIAGNOSTIC #1: Fork.join wrapper 调用 processor 之前 ===
-                Object inputData = input.getData();
+                O inputData = input.getData();
                 System.err.println(String.format(
                     "[DIAG-Fork:96-BEFORE] key=%s, thread=%s, branchCount=%d/%d, acc.first=%s, input.getData=%s, input.getData_is_null=%b",
                     key, Thread.currentThread().getName(), acc.second(), forkNumber.get(),

Original file line number	Diff line number	Diff line change
`@@ -95,7 +95,7 @@ public synchronized R process(FlowContext<O> input) {`
`95`	`95`	`}`
`96`	`96`
`97`	`97`	`// === DIAGNOSTIC #1: Fork.join wrapper 调用 processor 之前 ===`
`98`		`- Object inputData = input.getData();`
	`98`	`+ O inputData = input.getData();`
`99`	`99`	`System.err.println(String.format(`
`100`	`100`	`"[DIAG-Fork:96-BEFORE] key=%s, thread=%s, branchCount=%d/%d, acc.first=%s, input.getData=%s, input.getData_is_null=%b",`
`101`	`101`	`key, Thread.currentThread().getName(), acc.second(), forkNumber.get(),`