flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: Datasets union CompilerException
Date Tue, 30 Jun 2015 14:59:23 GMT
I don't think it is related, but another bug...

On Tue, Jun 30, 2015 at 4:44 PM, Michele Bertoni <
michele1.bertoni@mail.polimi.it> wrote:

>  Hi yesterday on the union I faced an other problem:
> at runtime it was saying something like “Union cannot work with dataset of
> two different types” then it was showing the types and they were exactly
> the same (Tuple5<Long, String, Long, Long, MyClass>
> I solved it changing on field of the tuple from a custom object (MyClass)
> that was containing only a double to a native double and it worked
>
>  I don’t know if it is related but it may be
>
>  Michele
>
>
>  Il giorno 30/giu/2015, alle ore 10:57, Fabian Hueske <fhueske@gmail.com>
> ha scritto:
>
>  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