[flink] branch master updated: [FLINK-11411][runtime] Properly log number of failover regions

[chesnay]

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 <wbeaglewatc...@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);