jinfeng created FLINK-20739: ------------------------------- Summary: Ban `if` from HiveModule Key: FLINK-20739 URL: https://issues.apache.org/jira/browse/FLINK-20739 Project: Flink Issue Type: Improvement Components: Connectors / Hive Affects Versions: 1.10.0 Reporter: jinfeng
When using hiveModule, the if function is treated as a normal function. If I have a SQL like this: {code:java} insert into Sink select if(size(split(`test`, '-')) > 1, split(`test`, '-')[10], 'error') from Source {code} It will throw arrayIndexOutOfBoundsException in Flink1.10, becase size(split(`test`, '-')) > 1 , split(`test`, '-')[10], ‘error’ will be calculated first, and then if function will be calculated -- This message was sent by Atlassian Jira (v8.3.4#803005)