Hi,
We have been doing some testing on flink jdbc connector rc2. We are testing
with Flink 1.1.8 jars and are using the TableEnvironment
TableResult<https://nightlies.apache.org/flink/flink-docs-master/api/java/org/apache/flink/table/api/TableResult.html>
executeSql(String<http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true>
statement). We hit some strange behaviour testing the lookup join, we got a
null pointer Exception on
https://github.com/apache/flink-connector-jdbc/blob/390d7bc9139204fbfc48fe275a69eb60c4807fb5/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java#L192
and that the constructor did not seem to be driven. We changed the release
that the pom file was building against to 1.18 and it works; so our issue
appeared to be mismatching jar levels. This issue did not appear running the
SQL client against rc2.
I am attempting to put a simple java test together to show this issue.
WDYT?
Kind regards.
Unless otherwise stated above:
IBM United Kingdom Limited
Registered in England and Wales with number 741598
Registered office: PO Box 41, North Harbour, Portsmouth, Hants. PO6 3AU
