[GitHub] lamber-ken commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

[GitBox]

lamber-ken commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp 
is inconsistent with currentProcessingTime()
URL: https://github.com/apache/flink/pull/7180#issuecomment-445109507
 
 
   @walterddr, you are welcome.
   flink sql use `CodeGenerator#generateProctimeTimestamp` method to process 
`proctime` and its type is `Timestamp`, flink use calcite to convert long to 
Timestamp
   
   but calcite implementation of the method as below, 
`SqlFunctions#internalToTime`
   ```
   public static java.sql.Time internalToTime(int v) {
       return new java.sql.Time(v - LOCAL_TZ.getOffset(v));
   }
   ```
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services