[BEAM-12608] Samza ValidatesRunner Reshuffle tests on Go SDK

• Type: Test
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: runner-samza, sdk-go
• Assignee: Unassigned
• Reporter: Ke Wu
• Created: 13/Jul/21 20:26
• Updated: 04/Jun/22 20:50

Description

Caused by: java.util.concurrent.ExecutionException: java.lang.RuntimeException: Error received from SDK harness for instruction 2: process bundle failed for instruction 2 using plan 2-3 : while executing Process for Plan[2-3]:
 2: DataSink[S[fn/write/n4:0@localhost:45186]] Coder:W;fn/wire/n4:0<KV;c7<int[varintz;c2];c3,int[varintz;c2];c3>>!GWC
 3: ParDo[beam.addFixedKeyFn] Out:[2]
 4: ReshuffleOutput[S[@]] Coder:W<int[varintz;c2];c3>!GWC
 1: DataSource[S[fn/read/n3_out:0@localhost:45186], local_output] Coder:W;fn/wire/n3_out:0<CoGBK;c6<int[varintz;c2];c3,bytes;c0>>!GWC Out:4
 caused by:
 source decode failed
 caused by:
 invalid varintz encoding for: []
 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
 at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895)
 at org.apache.beam.sdk.util.MoreFutures.get(MoreFutures.java:60)
 at org.apache.beam.runners.fnexecution.control.SdkHarnessClient$BundleProcessor$ActiveBundle.close(SdkHarnessClient.java:504)
 at org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$SimpleStageBundleFactory$1.close(DefaultJobBundleFactory.java:555)
 at org.apache.beam.runners.samza.runtime.SamzaDoFnRunners$SdkHarnessDoFnRunner.finishBundle(SamzaDoFnRunners.java:291)
 ... 202 more