xiaojin.wy created FLINK-23290:
----------------------------------
Summary: 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
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)
*After excuting that, you will get the error:
*
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)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
