[jira] [Created] (FLINK-20739) Ban `if` from HiveModule

[Shang Yuanchun (Jira)]

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)