[
https://issues.apache.org/jira/browse/FLINK-23290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-23290:
------------------------------------
Assignee: Caizhi Weng
> cast '(LZ *3' as boolean, get a null
> ------------------------------------
>
> Key: FLINK-23290
> URL: https://issues.apache.org/jira/browse/FLINK-23290
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Runtime
> Affects Versions: 1.14.0
> Reporter: xiaojin.wy
> Assignee: Caizhi Weng
> Priority: Major
>
> {code:sql}
> CREATE TABLE database5_t0(
> c0 VARCHAR , c1 BIGINT
> ) WITH (
> 'connector' = 'filesystem',
> 'path' = 'hdfs:///tmp/database5_t0.csv',
> 'format' = 'csv'
> );
> INSERT OVERWRITE database5_t0(c0, c1) VALUES('(LZ *3', 2135917226)
> SELECT database5_t0.c0 AS ref0 FROM database5_t0 WHERE CAST (database5_t0.c0
> AS BOOLEAN)
> {code}
> After excuting that, you will get the error:
> {code}
> Caused by: java.lang.NullPointerException
> at BatchExecCalc$20.processElement(Unknown Source)
> at
> org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:101)
> at
> org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:82)
> at
> org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:39)
> 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:319)
> at
> org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:414)
> at
> org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction.run(InputFormatSourceFunction.java:92)
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:104)
> at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:62)
> at
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:269)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
