I don't think it is related, but another bug...
On Tue, Jun 30, 2015 at 4:44 PM, Michele Bertoni <
michele1.bert...@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” the
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
I solved it changing on field of the tuple from a custom object (MyClass) that
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 :
> 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?
>
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 :
> Unfortunately not in public..moreover t
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 wrote:
> Hmm, that issue must have been introduced as part of a recent change.
>
> Can you share your program so we can reproduce
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" :
> Hi to all,
>
> I'm running my flink-job on the new 0.9.0 version of Flink and now I get
> this exception:
>
>
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.traversa
