Github user kmurra commented on the issue:
https://github.com/apache/flink/pull/4746
The biggest change here is in the test cases -- I generalized the test
table source to have some basic filtering logic and allow for generic datasets.
I moved the Literal build logic to the
RexNodeToExpressionConverter.visitLiteral. I also rewrote several of the
conversion methods to more closely align with the intended behavior of the code
- that we're preserving the string values of the various time-related literals
in the local timezone. This made a bunch of the epoch-millisecond
modifications go away.
---
