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 af0059c [FLINK-11693] Deprecate old constructors in modern
KafkaProducer
new db53a04 [hotfix][tests] Rewrite StreamTaskTest without reflection
based fields setting
new 1838e9c [hotfix][tests] StreamTaskTestHarness: create StreamTask
instance in the execution thread (task's thread)
new 9f55976 [hotfix][tests] Make SynchronousCheckpointTest create
StreamTask instance in the main task's thread
new 812a3f3 [hotfix][tests] StreamTaskTestHarness: use
Preconditions.checkState instead of explicit throw IllegalStateException
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../streaming/runtime/tasks/StreamTaskTest.java | 522 ++++++++++-----------
.../runtime/tasks/StreamTaskTestHarness.java | 59 ++-
.../runtime/tasks/SynchronousCheckpointTest.java | 3 +-
.../util/{NoOpIntMap.java => StreamTaskUtil.java} | 20 +-
4 files changed, 294 insertions(+), 310 deletions(-)
copy
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/{NoOpIntMap.java
=> StreamTaskUtil.java} (64%)
