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:57:02 GMT
Also, can you open a JIRA for the issue? Otherwise it might get lost on the
mailing list.

Thanks you!

2015-06-30 10:56 GMT+02:00 Fabian Hueske <fhueske@gmail.com>:

> 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