This is an automated email from the ASF dual-hosted git repository.
nkruber pushed a change to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 10f155e [BP-1.10][FLINK-20013][network] BoundedBlockingSubpartition
may leak network buffer if task is failed or canceled
add a14665d [FLINK-16753] Use CheckpointException to wrap exceptions
thrown from StreamTask (#14071)
No new revisions were added by this update.
Summary of changes:
.../checkpoint/CheckpointFailureManager.java | 1 +
.../checkpoint/CheckpointFailureReason.java | 2 +
.../flink/streaming/runtime/tasks/StreamTask.java | 4 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 66 ++++++++++++++++++++++
4 files changed, 72 insertions(+), 1 deletion(-)
