You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jingsong Lee (Jira)" <ji...@apache.org> on 2021/07/12 02:52:00 UTC
[jira] [Assigned] (FLINK-22985) NullPointerException when cast
string literal to date or time
[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jingsong Lee reassigned FLINK-22985:
------------------------------------
Assignee: Caizhi Weng
> NullPointerException when cast string literal to date or time
> -------------------------------------------------------------
>
> 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
> Assignee: Caizhi Weng
> Priority: Major
> 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)