You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Kenneth Knowles (Jira)" <ji...@apache.org> on 2021/07/13 20:27:00 UTC
[jira] [Updated] (BEAM-12608) Samza ValidatesRunner Reshuffle tests
on Go SDK
[ https://issues.apache.org/jira/browse/BEAM-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kenneth Knowles updated BEAM-12608:
-----------------------------------
Status: Open (was: Triage Needed)
> Samza ValidatesRunner Reshuffle tests on Go SDK
> -----------------------------------------------
>
> Key: BEAM-12608
> URL: https://issues.apache.org/jira/browse/BEAM-12608
> Project: Beam
> Issue Type: Test
> Components: runner-samza, sdk-go
> Reporter: Ke Wu
> Assignee: Ke Wu
> Priority: P3
>
> {code:java}
> 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
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)