[FLINK-33233] Null point exception when non-native udf used in join condition

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.17.0
• Fix Version/s: 1.19.0, 1.17.3, 1.18.2
• Component/s: Connectors / Hive
• Labels: pull-request-available
• Assignee: yunfan
• Reporter: yunfan
• Created: 10/Oct/23 13:49
• Updated: 24/Jan/24 04:03
• Resolved: 24/Jan/24 04:03

Description

Any non-native udf used in hive-parser join condition. 

It will caused NullPointException.

It can reproduced by follow code by adding this test to 

org.apache.flink.connectors.hive.HiveDialectQueryITCase

 

// 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]]");
} 

Issue Links

• links to: GitHub Pull Request #23504
• links to: GitHub Pull Request #24148
• links to: GitHub Pull Request #24149