You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "simenliuxing (Jira)" <ji...@apache.org> on 2021/06/15 03:00:00 UTC
[jira] [Created] (FLINK-22985) sql syntax, NullPointerException
simenliuxing created FLINK-22985:
------------------------------------
Summary: sql syntax, NullPointerException
Key: FLINK-22985
URL: https://issues.apache.org/jira/browse/FLINK-22985
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Affects Versions: 1.13.1
Reporter: simenliuxing
Fix For: 1.14.0
sql:
{code:java}
CREATE TABLE source_table
(
id INT,
score INT,
address STRING,
create_time TIME,
create_date DATE,
create_timestamp TIMESTAMP
) WITH (
'connector' = 'datagen'
);
CREATE TABLE console_table
(
create_time TIME,
create_date DATE,
create_timestamp TIMESTAMP
) WITH (
'connector' = 'print'
);
INSERT INTO console_table
SELECT CASE
WHEN A.create_time IS NULL
OR A.create_time = '' THEN CURRENT_TIME
ELSE A.create_time
END
AS create_time,
CASE
WHEN A.create_date IS NULL
OR A.create_date = '' THEN CURRENT_DATE
ELSE A.create_date
END
AS create_date,
CASE
WHEN A.create_timestamp IS NULL
OR A.create_timestamp = '' THEN CURRENT_TIMESTAMP
ELSE A.create_timestamp
END
AS create_timestamp
FROM source_table A;
{code}
exception:
{code:java}
java.lang.RuntimeException: Could not instantiate generated class 'StreamExecCalc$23'java.lang.RuntimeException: Could not instantiate generated class 'StreamExecCalc$23' at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:66) at org.apache.flink.table.runtime.operators.CodeGenOperatorFactory.createStreamOperator(CodeGenOperatorFactory.java:40) at org.apache.flink.streaming.api.operators.StreamOperatorFactoryUtil.createOperator(StreamOperatorFactoryUtil.java:80) at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:652) at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:626) at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:566) at org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:181) at org.apache.flink.streaming.runtime.tasks.StreamTask.executeRestore(StreamTask.java:548) at org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:647) at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:537) at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:759) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566) at java.lang.Thread.run(Thread.java:748)Caused by: java.lang.reflect.InvocationTargetException at sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:64) ... 12 moreCaused by: java.lang.NullPointerException at StreamExecCalc$23.<init>(Unknown Source) ... 16 more
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)