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
