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

["Sathya Hariesh (JIRA)" <ji...@apache.org>]

Sathya Hariesh created BEAM-1642:
------------------------------------

             Summary: 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.5.0, 0.4.0, 0.6.0
            Reporter: Sathya Hariesh
            Assignee: Thomas Groh
            Priority: Trivial


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)