yunfan created FLINK-33233: ------------------------------ Summary: Null point exception when non-native udf used in join condition Key: FLINK-33233 URL: https://issues.apache.org/jira/browse/FLINK-33233 Project: Flink Issue Type: Improvement Components: Connectors / Hive Affects Versions: 1.17.0 Environment: It can reproduced by follow code by adding this test to {code:java} org.apache.flink.connectors.hive.HiveDialectQueryITCase{code} {code:java} // Add follow code to org.apache.flink.connectors.hive.HiveDialectQueryITCase @Test public void testUdfInJoinCondition() throws Exception { List<Row> result = CollectionUtil.iteratorToList(tableEnv.executeSql( "select foo.y, bar.I from bar join foo on hiveudf(foo.x) = bar.I where bar.I > 1").collect()); assertThat(result.toString()) .isEqualTo("[+I[2, 2]]"); } {code} Reporter: yunfan
Any non-native udf used in hive-parser join condition. It will caused NullPointException. -- This message was sent by Atlassian Jira (v8.20.10#820010)