@@ -596,18 +596,18 @@ public final AiState<Tip, D, Tip, RF, F> runnableParallel(Pattern<O, Tip>... pat
596596
597597 AiState <Tip , D , Tip , RF , F > state = aiFork .join (Tip ::new , (acc , data ) -> {
598598 // 诊断日志:记录每次reducer调用的详细信息
599- log .debug ("[Fork.join reducer] Thread={}, acc={}, data={}, data_is_null={}" ,
599+ log .warn ("[DIAGNOSTIC Fork.join reducer] Thread={}, acc={}, data={}, data_is_null={}" ,
600600 Thread .currentThread ().getName (),
601601 acc ,
602602 data ,
603603 data == null );
604604
605605 // Tip.merge() 内部会处理 data 为 null 的情况
606606 if (data == null ) {
607- log .warn ("[Fork.join reducer] DIAGNOSTIC: Received null data in reducer! acc={}, thread={}" ,
607+ log .warn ("[DIAGNOSTIC Fork.join reducer] Received null data in reducer! acc={}, thread={}" ,
608608 acc , Thread .currentThread ().getName ());
609609 // 打印堆栈跟踪以了解调用路径
610- log .warn ("[Fork.join reducer] Stack trace:" , new RuntimeException ("null data diagnostic" ));
610+ log .warn ("[DIAGNOSTIC Fork.join reducer] Stack trace:" , new RuntimeException ("null data diagnostic" ));
611611 }
612612 acc .merge (data );
613613 return acc ;
@@ -620,20 +620,20 @@ private Processor<O, Tip> getPatternProcessor(Pattern<O, Tip> pattern, AiState<O
620620 return node .publisher ()
621621 .map (input -> {
622622 O inputData = input .getData ();
623- log .debug ("[getPatternProcessor] Executing pattern={}, inputData={}, thread={}" ,
623+ log .warn ("[DIAGNOSTIC getPatternProcessor] Executing pattern={}, inputData={}, thread={}" ,
624624 pattern .getClass ().getSimpleName (),
625625 inputData ,
626626 Thread .currentThread ().getName ());
627627
628628 Tip result = AiFlowSession .applyPattern (pattern , inputData , input .getSession ());
629629
630- log .debug ("[getPatternProcessor] Pattern result={}, result_is_null={}, thread={}" ,
630+ log .warn ("[DIAGNOSTIC getPatternProcessor] Pattern result={}, result_is_null={}, thread={}" ,
631631 result ,
632632 result == null ,
633633 Thread .currentThread ().getName ());
634634
635635 if (result == null ) {
636- log .error ("[getPatternProcessor] CRITICAL: Pattern returned null! pattern={}, inputData={}" ,
636+ log .error ("[DIAGNOSTIC getPatternProcessor] CRITICAL: Pattern returned null! pattern={}, inputData={}" ,
637637 pattern .getClass ().getSimpleName (),
638638 inputData );
639639 }
0 commit comments