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)
