You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/01/28 23:22:50 UTC
[flink] branch master updated: [FLINK-11411][runtime] Properly log
number of failover regions
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 35fa2b7 [FLINK-11411][runtime] Properly log number of failover regions
35fa2b7 is described below
commit 35fa2b71255b2e1ffa910ebcaf05949b0e7a80f1
Author: Bo WANG <wb...@gmail.com>
AuthorDate: Tue Jan 29 07:22:42 2019 +0800
[FLINK-11411][runtime] Properly log number of failover regions
---
.../runtime/executiongraph/failover/RestartPipelinedRegionStrategy.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/RestartPipelinedRegionStrategy.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/RestartPipelinedRegionStrategy.java
index b8f6964..c93a887 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/RestartPipelinedRegionStrategy.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/RestartPipelinedRegionStrategy.java
@@ -206,7 +206,7 @@ public class RestartPipelinedRegionStrategy extends FailoverStrategy {
// now that we have all regions, create the failover region objects
LOG.info("Creating {} individual failover regions for job {} ({})",
- executionGraph.getJobName(), executionGraph.getJobID());
+ distinctRegions.size(), executionGraph.getJobName(), executionGraph.getJobID());
for (List<ExecutionVertex> region : distinctRegions.keySet()) {
final FailoverRegion failoverRegion = new FailoverRegion(executionGraph, executor, region);