jack wang created FLINK-22943:
---------------------------------
Summary: java.lang.ClassCastException: java.time.Instant cannot be cast to java.sql.Timestamp
Key: FLINK-22943
URL:
https://issues.apache.org/jira/browse/FLINK-22943 Project: Flink
Issue Type: Bug
Components: Connectors / Hive
Affects Versions: 1.13.1
Reporter: jack wang
Before 3.1.2 of hive version, getQueryCurrentTimestamp return Timestamp. But when hive version is 3.1.2，getCurrentTSMethod invoke return Instant. So the code `(Timestamp)getCurrentTSMethod.invoke(sessionState)` will result the ClassCastException. It should be compatibility with this situation.
when I use hive dialect to create hive table, it will tirgger this error. The error is below:
Exception in thread "main" java.lang.ClassCastException: java.time.Instant cannot be cast to java.sql.TimestampException in thread "main" java.lang.ClassCastException: java.time.Instant cannot be cast to java.sql.Timestamp at org.apache.flink.table.planner.delegation.hive.HiveParser.setCurrentTimestamp(HiveParser.java:365) at org.apache.flink.table.planner.delegation.hive.HiveParser.startSessionState(HiveParser.java:350) at org.apache.flink.table.planner.delegation.hive.HiveParser.parse(HiveParser.java:218) at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:722)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
Locked
