This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f65be9b [FLINK-14953][formats] use table type to build parquet
FilterPredicate
add 7f797e0 [FLINK-15076][task] Fix SourceStreamTask cancellation
No new revisions were added by this update.
Summary of changes:
.../streaming/runtime/tasks/SourceStreamTask.java | 9 +-
.../flink/streaming/runtime/tasks/StreamTask.java | 22 ++-
.../runtime/tasks/SourceStreamTaskTest.java | 179 ++++++++++++++++++++-
3 files changed, 199 insertions(+), 11 deletions(-)
