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/07/02 15:08:17 UTC
[flink] 03/05: [hotfix][runtime] Remove obsolete comment from
PipelinedRegionComputeUtil#uniqueRegions()
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 <ga...@apache.org>
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;