emit plan from logs

apache · May 6, 2024 · a7b8efc · a7b8efc
1 parent 0954f09
commit a7b8efc
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/sdks/go/pkg/beam/core/runtime/exec/sdf.go b/sdks/go/pkg/beam/core/runtime/exec/sdf.go
@@ -918,6 +918,7 @@ func (n *ProcessSizedElementsAndRestrictions) newSplitResult(ctx context.Context
 		Elm2:      size,
 		Timestamp: n.elm.Timestamp,
 		Windows:   w,
+		Pane:      n.elm.Pane,
 	}, nil
 }
 

diff --git a/sdks/go/pkg/beam/core/runtime/harness/harness.go b/sdks/go/pkg/beam/core/runtime/harness/harness.go
@@ -388,7 +388,7 @@ func (c *control) handleInstruction(ctx context.Context, req *fnpb.InstructionRe
 		bdID := bundleDescriptorID(msg.GetProcessBundleDescriptorId())
 
 		// TODO(lostluck): 2023/03/29 fix debug level logging to be flagged.
-		// log.Debugf(ctx, "PB [%v]: %v", instID, msg)
+		log.Debugf(ctx, "PB [%v]: %v", instID, msg)
 		plan, err := c.getOrCreatePlan(bdID)
 
 		// Make the plan active.