This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b3ded50 [hotfix][yarn] Rename YarnTaskExecutorRunner#run to
#runTaskManagerSecurely
add a62e1ac [FLINK-14890] Add broadcast operators test harnesses
add 10c0cd8 [FLINK-14890] Add utility class for initializing various
process function test harnesses
add ed99909 [FLINK-14890] Add ProcessFunctionTestHarnesses tests
add 2891a53 [FLINK-14809] Use StreamRecord matchers in
ProcessFunctionTestHarnessTest
add 93110d9 [minor] Move StreamRecordMatchers to util package
add 23e62e4 [minor] Rename StreamRecordMatchers.isStreamRecord() to
streamRecord()
No new revisions were added by this update.
Summary of changes:
.../DynamicEventTimeSessionWindowsTest.java | 2 +-
.../DynamicProcessingTimeSessionWindowsTest.java | 2 +-
.../windowing/EventTimeSessionWindowsTest.java | 2 +-
.../ProcessingTimeSessionWindowsTest.java | 2 +-
.../windowing/SlidingEventTimeWindowsTest.java | 2 +-
.../SlidingProcessingTimeWindowsTest.java | 2 +-
.../windowing/TumblingEventTimeWindowsTest.java | 2 +-
.../TumblingProcessingTimeWindowsTest.java | 2 +-
.../windowing/WindowOperatorContractTest.java | 14 +-
...AbstractBroadcastStreamOperatorTestHarness.java | 79 ++++++++
.../util/BroadcastOperatorTestHarness.java | 58 ++++++
.../util/KeyedBroadcastOperatorTestHarness.java | 70 +++++++
.../util/ProcessFunctionTestHarnesses.java | 215 +++++++++++++++++++++
.../util/ProcessFunctionTestHarnessesTest.java | 180 +++++++++++++++++
.../windowing => util}/StreamRecordMatchers.java | 15 +-
.../util/TwoInputStreamOperatorTestHarness.java | 8 +
16 files changed, 633 insertions(+), 22 deletions(-)
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractBroadcastStreamOperatorTestHarness.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/BroadcastOperatorTestHarness.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/KeyedBroadcastOperatorTestHarness.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/ProcessFunctionTestHarnesses.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/ProcessFunctionTestHarnessesTest.java
rename
flink-streaming-java/src/test/java/org/apache/flink/streaming/{runtime/operators/windowing
=> util}/StreamRecordMatchers.java (92%)
