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 654a637 [FLINK-17604][csv] Implement format factory for CSV
serialization and deseriazation schema of RowData type
add 7e23ceb [FLINK-17663][task][hotfix] Do not hide original exception in
case of a secondary failure during task clean up
add 0ca918d [FLINK-17663][network] Properly support UnionInputGates with
unaligned checkpoints
No new revisions were added by this update.
Summary of changes:
.../streaming/runtime/io/InputProcessorUtil.java | 29 +++++++++-----
.../runtime/tasks/MultipleInputStreamTask.java | 9 +----
.../runtime/tasks/OneInputStreamTask.java | 5 +--
.../flink/streaming/runtime/tasks/StreamTask.java | 12 +++++-
.../runtime/tasks/TwoInputStreamTask.java | 9 +----
.../streaming/runtime/tasks/StreamTaskTest.java | 44 ++++++++++++++++++++++
6 files changed, 77 insertions(+), 31 deletions(-)
