[ https://issues.apache.org/jira/browse/FLINK-31007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
lincoln lee reassigned FLINK-31007: ----------------------------------- Assignee: xzw0223 > The code generated by the IF function throws NullPointerException > ----------------------------------------------------------------- > > Key: FLINK-31007 > URL: https://issues.apache.org/jira/browse/FLINK-31007 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner, Table SQL / Runtime > Affects Versions: 1.15.2, 1.15.3 > Environment: {code:java} > // code placeholder > final StreamExecutionEnvironment env = > StreamExecutionEnvironment.getExecutionEnvironment(); > env.setParallelism(1); > final StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env); > final DataStream<Tuple2> tab = > env.fromCollection(Arrays.asList( > new Tuple2<>(1L, "a_b_c"), > new Tuple2<>(-1L, "a_b_c"))); > final Table tableA = tableEnv.fromDataStream(tab); > tableEnv.executeSql("SELECT if(f0 = -1, '', split_index(f1, '_', 0)) as id > FROM " + tableA) > .print(); {code} > Reporter: tivanli > Assignee: xzw0223 > Priority: Major > Attachments: StreamExecCalc$19.java, image-2023-02-10-17-20-51-619.png > > > Caused by: java.lang.NullPointerException > at StreamExecCalc$19.processElement_split1(Unknown Source) > at StreamExecCalc$19.processElement(Unknown Source) > at > org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82) > at > org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57) > at > org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29) > at > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56) > at > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29) > at > org.apache.flink.table.runtime.operators.source.InputConversionOperator.processElement(InputConversionOperator.java:128) > at > org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82) > at > org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57) > at > org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29) > at > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56) > at > org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29) > at > org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:418) > at > org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:513) > at > org.apache.flink.streaming.api.operators.StreamSourceContexts$SwitchingOnClose.collect(StreamSourceContexts.java:103) > at > org.apache.flink.streaming.api.functions.source.FromElementsFunction.run(FromElementsFunction.java:231) > at > org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110) > at > org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67) > at > org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:332) -- This message was sent by Atlassian Jira (v8.20.10#820010)