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
commit efebb99d5d3840047741cde4a73511252bd76e93 Author: Gary Yao <[email protected]> AuthorDate: Thu Jun 20 17:23:21 2019 +0200 [hotfix][runtime] Remove obsolete comment from PipelinedRegionComputeUtil#uniqueRegions() --- .../executiongraph/failover/flip1/PipelinedRegionComputeUtil.java | 1 - 1 file changed, 1 deletion(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/PipelinedRegionComputeUtil.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/PipelinedRegionComputeUtil.java index b21b52f..14d28b7 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/PipelinedRegionComputeUtil.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/PipelinedRegionComputeUtil.java @@ -103,7 +103,6 @@ public final class PipelinedRegionComputeUtil { } private static Set<Set<FailoverVertex>> uniqueRegions(final Map<FailoverVertex, Set<FailoverVertex>> vertexToRegion) { - // find out all the distinct regions final Set<Set<FailoverVertex>> distinctRegions = Collections.newSetFromMap(new IdentityHashMap<>()); distinctRegions.addAll(vertexToRegion.values()); return distinctRegions;
