You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2020/09/03 14:32:42 UTC
[flink] branch master updated (34925af -> d7fe9af)
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 34925af [FLINK-18513][Kinesis] Omitting AWS SDK services from shaded jar
add d7fe9af [FLINK-14087][datastream] Clone the StreamPartitioner to avoid being shared at runtime.
No new revisions were added by this update.
Summary of changes:
.../flink/streaming/runtime/tasks/StreamTask.java | 16 ++-
.../DataStreamWithSharedPartitionNodeITCase.java | 109 +++++++++++++++++++++
2 files changed, 123 insertions(+), 2 deletions(-)
create mode 100644 flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/DataStreamWithSharedPartitionNodeITCase.java