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 >> >
