[
https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378877#comment-17378877
]
Caizhi Weng commented on FLINK-22985:
-------------------------------------
After researching on the behavior of some databases, I found that postgre
throws an exception when compiling, notifying the user that their given string
has an invalid time format. [~lzljs3620320] and I both agree that this is the
most suitable behavior so I'm going to fix this issue by throwing a proper
exception.
> 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)
