This is an automated email from the ASF dual-hosted git repository. libenchao pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from a8c7b50 [FLINK-19590] Fix the compile issue of flink-streaming-java module add 29a5135 [FLINK-19336][table] EncodingUtils#encodeObjectToString should propagate inner exception add b5b3065 [FLINK-18850][table-runtime-blink] Add late records dropped metric for row time over windows No new revisions were added by this update. Summary of changes: .../apache/flink/table/utils/EncodingUtils.java | 2 +- .../AbstractRowTimeUnboundedPrecedingOver.java | 20 ++++++- .../over/RowTimeRangeBoundedPrecedingFunction.java | 18 +++++++ .../over/RowTimeRowsBoundedPrecedingFunction.java | 18 +++++++ ...ionTest.java => RowTimeOverWindowTestBase.java} | 57 ++++---------------- .../RowTimeRangeBoundedPrecedingFunctionTest.java | 55 +++++++++---------- ...RowTimeRangeUnboundedPrecedingFunctionTest.java | 61 +++++++++++++++++++++ .../RowTimeRowsBoundedPrecedingFunctionTest.java | 62 ++++++++++++++++++++++ .../RowTimeRowsUnboundedPrecedingFunctionTest.java | 61 +++++++++++++++++++++ 9 files changed, 275 insertions(+), 79 deletions(-) copy flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/over/{ProcTimeRangeBoundedPrecedingFunctionTest.java => RowTimeOverWindowTestBase.java} (50%) create mode 100644 flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/over/RowTimeRangeUnboundedPrecedingFunctionTest.java create mode 100644 flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/over/RowTimeRowsBoundedPrecedingFunctionTest.java create mode 100644 flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/over/RowTimeRowsUnboundedPrecedingFunctionTest.java