You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2017/09/07 06:19:26 UTC
[2/6] flink git commit: [hotfix] [kafka] Remove unused
shouldAssignToThisSubtask method in AbstractPartitionDiscoverer
[hotfix] [kafka] Remove unused shouldAssignToThisSubtask method in AbstractPartitionDiscoverer
This closes #4526.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/36412c6f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/36412c6f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/36412c6f
Branch: refs/heads/master
Commit: 36412c6f640f1b20070461f3b25f1453c93d194d
Parents: 93369e7
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
Authored: Fri Aug 11 15:57:52 2017 +0800
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Thu Sep 7 12:54:06 2017 +0800
----------------------------------------------------------------------
.../connectors/kafka/internals/AbstractPartitionDiscoverer.java | 4 ----
1 file changed, 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/36412c6f/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java
index 8240f60..b336fdc 100644
--- a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java
+++ b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java
@@ -244,8 +244,4 @@ public abstract class AbstractPartitionDiscoverer {
private boolean isUndiscoveredPartition(KafkaTopicPartition partition) {
return !discoveredPartitions.contains(partition);
}
-
- public static boolean shouldAssignToThisSubtask(KafkaTopicPartition partition, int indexOfThisSubtask, int numParallelSubtasks) {
- return Math.abs(partition.hashCode() % numParallelSubtasks) == indexOfThisSubtask;
- }
}