It seems as if
FLINK-13993 made the Table API (Blink planner) unusable for POJO sources where the POJO class is in user code.
For https://github.com/ververica/lab-sql-vs-datastream/blob/master/src/main/java/com/ververica/LateralTableJoin.java I get the following Exception when I run it on a Flink 1.10.0 cluster (full version attached):
I enabled debug logs and this is what it is trying to compile:
I use a standalone cluster and submit via web UI and also verified that my jar file does not contain anything else but its compiled classes.
This code is working fine inside the IDE and was also working with Flink 1.10 and VVP 2.0 which did not use a dedicated class loader for user code.
My guess is that the (generated) code does not have access to FactTable.Fact and the Janino compiler does not produce the right error message seeing "com" as a primitive type instead.