You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by se...@apache.org on 2021/11/19 00:07:14 UTC

[flink] branch release-1.13 updated (b9c729e -> a3a776d)

This is an automated email from the ASF dual-hosted git repository.

sewen pushed a change to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from b9c729e  [FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods
     add a72bd1c  [FLINK-24366][runtime] Don't log error for failed task restore if the task is already canceled.
     add 20323e3  [FLINK-24255][tests] Test environments respect configuration when being instantiated.
     add a3a776d  [FLINK-23842][coordination] Add logging statements in SourceCoordinators for reader registration and split requests.

No new revisions were added by this update.

Summary of changes:
 .../source/coordinator/SourceCoordinator.java      | 29 ++++++++++++++++------
 .../api/operators/BackendRestorerProcedure.java    | 12 ++++-----
 .../streaming/util/TestStreamEnvironment.java      | 13 +++++++---
 .../MiniClusterPipelineExecutorServiceLoader.java  | 25 ++++++++++++++++---
 .../apache/flink/test/util/TestEnvironment.java    |  4 ++-
 5 files changed, 62 insertions(+), 21 deletions(-)