[jira] [Closed] (BEAM-1642) Combine transformation evaluation fails on direct runner with Avro as a fallback coder

["Daniel Halperin (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BEAM-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Daniel Halperin closed BEAM-1642.
---------------------------------
    Resolution: Fixed

> Combine transformation evaluation fails on direct runner with Avro as a fallback coder
> --------------------------------------------------------------------------------------
>
>                 Key: BEAM-1642
>                 URL: https://issues.apache.org/jira/browse/BEAM-1642
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-direct
>    Affects Versions: 0.4.0, 0.5.0, 0.6.0
>            Reporter: Sathya Hariesh
>            Assignee: Robert Bradshaw
>            Priority: Trivial
>             Fix For: First stable release
>
>
> This does not happen in 0.3.0. Would probably need to investigate the root cause.
> Steps to reproduce:
> public class WordCount {
>     public static void main(String[] args) {
>         DirectOptions directPipelineOptions = PipelineOptionsFactory.as(DirectOptions.class);
>         directPipelineOptions.setRunner(DirectRunner.class);
>         Pipeline pipeline = Pipeline.create(directPipelineOptions);
>         pipeline.getCoderRegistry().setFallbackCoderProvider(AvroCoder.PROVIDER);
>         pipeline.apply(Create.of(Arrays.asList(100, 200))).apply(Count.globally());
>         pipeline.run().waitUntilFinish();
>     }
> }
> Stack trace:
> Exception in thread "main" java.lang.ClassCastException: java.lang.Object cannot be cast to java.lang.Iterable
> 	at org.apache.beam.runners.direct.ViewEvaluatorFactory$1.processElement(ViewEvaluatorFactory.java:81)
> 	at org.apache.beam.runners.direct.TransformExecutor.processElements(TransformExecutor.java:139)
> 	at org.apache.beam.runners.direct.TransformExecutor.run(TransformExecutor.java:107)
> 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> 	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> 	at java.lang.Thread.run(Thread.java:745)



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)