Could you try to use blink planner? I guess this works in blink planner.
Besides, it is suggested to use String with null values instead of
Option[String].
Flink SQL/Table doesn't know Option and will recognize it as a RAW/Generic
type which is rather slower.
There should be no NPE, otherwise, it
Hi, all
I am trying to join two datastream whose element types are respectively
```
case class MyEvent(
_id: Long = 0L,
_cId: Long = 0L,
_url: Option[String] = None,
)
```
and
```
case class MyCategory(
_id: Long = 0L,
_name: Option[String] = None,
)
```
When I tried to join those two tables with
