flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Datasets union CompilerException
Date Tue, 30 Jun 2015 08:56:32 GMT
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 <pompermaier@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 <sewen@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" <pompermaier@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
>>>
>>
>

Mime
View raw message