I'm not sure what exactly is the problem, but could you check this FAQ item?
http://flink.apache.org/faq.html#why-am-i-getting-a-nonserializableexception-
Best,
Gábor
2017-02-10 14:16 GMT+01:00 Sebastian Neef :
> Hi,
>
> thanks! That's exactly what I needed.
>
> I'm not using: DataSetA.leftOute
Hi,
thanks! That's exactly what I needed.
I'm not using: DataSetA.leftOuterJoin(DataSetB).where(new
KeySelector()).equalTo(new KeySelector()).with(new JoinFunction(...)).
Now I get the following error:
> Caused by: org.apache.flink.optimizer.CompilerException: Error translating
> node 'Map "Ke
Hello Sebastian,
You can use DataSet.leftOuterJoin for this.
Best,
Gábor
2017-02-10 12:58 GMT+01:00 Sebastian Neef :
> Hi,
>
> is it possible to assign a "default" value to elements that didn't match?
>
> For example I have the following two datasets:
>
> |DataSetA | DataSetB|
> -
Hi,
is it possible to assign a "default" value to elements that didn't match?
For example I have the following two datasets:
|DataSetA | DataSetB|
-
|id=1 | id=1
|id=2 | id=3
|id=5 | id=4
|id=6 | id=6
When doing a join with:
A.join(B).where( KeySelector(A.id
