This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from ad16e2c [FLINK-24889][table] Support casting MULTISET to STRING
new c2f510f [hotfix][coordination] Improve hint to build akka RPC system.
new e6798c3 [FLINK-24366][runtime] Don't log error for failed task
restore if the task is already canceled.
new 57253c5 [FLINK-24255][tests] Test environments respect configuration
when being instantiated.
new 7a10982 [FLINK-23842][coordination] Add logging statements in
SourceCoordinators for reader registration and split requests.
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../runtime/rpc/akka/AkkaRpcSystemLoader.java | 2 +-
.../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 ++-
6 files changed, 63 insertions(+), 22 deletions(-)
