This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 1fd9018 [FLINK-23651][python] Support RabbitMQ in PyFlink
add e022af9 [hotfix][test] Remove unwanted timeout inside the test
add d2200cc [hotfix][test] Do not hide original exception in the tests
add 2c26c0d [hotfix][test] Create a dedicated file for StreamTask
cancellation tests
add f133414 [hotfix][test] Remove unused class in StreamTaskTest
add 6eb29c9 [hotfix][test] Move LocalBufferPool destroy tests to
LocalBufferPoolDestroyTest file
No new revisions were added by this update.
Summary of changes:
.../network/buffer/LocalBufferPoolDestroyTest.java | 19 +-
.../io/network/buffer/LocalBufferPoolTest.java | 78 -----
.../taskexecutor/TaskExecutorSubmissionTest.java | 20 +-
.../runtime/tasks/StreamTaskCancellationTest.java | 338 +++++++++++++++++++++
.../runtime/tasks/StreamTaskTerminationTest.java | 4 -
.../streaming/runtime/tasks/StreamTaskTest.java | 303 ------------------
.../flink/test/cancelling/CancelingTestBase.java | 6 +-
.../flink/test/recovery/FastFailuresITCase.java | 12 +-
8 files changed, 367 insertions(+), 413 deletions(-)
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskCancellationTest.java
