You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2021/03/18 08:45:46 UTC
[flink] 01/04: [hotfix] Remove redundant sanity check in
EdgeManager#connectPartitionWithConsumerVertexGroup
This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit f7ec29cb993cc6032172e832c334ade4f0cabf0a
Author: Thesharing <cy...@outlook.com>
AuthorDate: Mon Mar 8 19:27:33 2021 +0800
[hotfix] Remove redundant sanity check in EdgeManager#connectPartitionWithConsumerVertexGroup
---
.../java/org/apache/flink/runtime/executiongraph/EdgeManager.java | 5 -----
1 file changed, 5 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManager.java
index a4d6aba..42ccfa3 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManager.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManager.java
@@ -47,11 +47,6 @@ public class EdgeManager {
checkNotNull(consumerVertexGroup);
- checkState(
- !partitionConsumers.containsKey(resultPartitionId),
- "There can only be a single consumer for the result partition %s.",
- resultPartitionId);
-
final List<ConsumerVertexGroup> consumers =
getConsumerVertexGroupsForPartitionInternal(resultPartitionId);