[jira] [Created] (FLINK-22943) java.lang.ClassCastException: java.time.Instant cannot be cast to java.sql.Timestamp

["jack wang (Jira)" <ji...@apache.org>]

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)