Hi, is it possible to get a smaller version of that program that reproduces the bug or give a few more details about the structure of the job? Without any hints, it is very hard to reproduce and fix the bug.
2015-06-24 18:23 GMT+02:00 Flavio Pompermaier <pomperma...@okkam.it>: > Unfortunately not in public..moreover this error seems to be non > deterministic..sometime the programs runs correctly :( > > On Wed, Jun 24, 2015 at 6:04 PM, Stephan Ewen <se...@apache.org> wrote: > >> Hmm, that issue must have been introduced as part of a recent change. >> >> Can you share your program so we can reproduce abs fix the bug? >> Am 24.06.2015 16:56 schrieb "Flavio Pompermaier" <pomperma...@okkam.it>: >> >>> Hi to all, >>> >>> I'm running my flink-job on the new 0.9.0 version of Flink and now I get >>> this exception: >>> >>> Exception in thread "main" org.apache.flink.optimizer.CompilerException: >>> Bug: Plan generation for Unions picked a ship strategy between binary plan >>> operators. >>> at >>> org.apache.flink.optimizer.traversals.BinaryUnionReplacer.collect(BinaryUnionReplacer.java:113) >>> at >>> org.apache.flink.optimizer.traversals.BinaryUnionReplacer.postVisit(BinaryUnionReplacer.java:72) >>> at >>> org.apache.flink.optimizer.traversals.BinaryUnionReplacer.postVisit(BinaryUnionReplacer.java:41) >>> at >>> org.apache.flink.optimizer.plan.DualInputPlanNode.accept(DualInputPlanNode.java:170) >>> at >>> org.apache.flink.optimizer.plan.SingleInputPlanNode.accept(SingleInputPlanNode.java:199) >>> at >>> org.apache.flink.optimizer.plan.DualInputPlanNode.accept(DualInputPlanNode.java:163) >>> at >>> org.apache.flink.optimizer.plan.DualInputPlanNode.accept(DualInputPlanNode.java:163) >>> at >>> org.apache.flink.optimizer.plan.SingleInputPlanNode.accept(SingleInputPlanNode.java:199) >>> at >>> org.apache.flink.optimizer.plan.SingleInputPlanNode.accept(SingleInputPlanNode.java:199) >>> at >>> org.apache.flink.optimizer.plan.SingleInputPlanNode.accept(SingleInputPlanNode.java:199) >>> at >>> org.apache.flink.optimizer.plan.SingleInputPlanNode.accept(SingleInputPlanNode.java:199) >>> at >>> org.apache.flink.optimizer.plan.OptimizedPlan.accept(OptimizedPlan.java:127) >>> at org.apache.flink.optimizer.Optimizer.compile(Optimizer.java:520) >>> at org.apache.flink.optimizer.Optimizer.compile(Optimizer.java:402) >>> at >>> org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:173) >>> at >>> org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:54) >>> at >>> org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:789) >>> >>> How can I fix that? >>> >>> Best, >>> Flavio >>> >> >
