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 d38bd89 [FLINK-18907][test] Add stream status forwarding test for
chained sources
add 7bfd8ec [FLINK-19411][task] Fix construction of
MultipleInputStreamTask with union inputs
No new revisions were added by this update.
Summary of changes:
.../runtime/io/StreamMultipleInputProcessor.java | 6 +++
.../runtime/tasks/MultipleInputStreamTask.java | 22 +++++---
.../streaming/runtime/MultipleInputITCase.java | 58 +++++++++++++++++-----
3 files changed, 66 insertions(+), 20 deletions(-)
