Repository: kafka Updated Branches: refs/heads/trunk 778fcd0e9 -> 8d303d0d3
KAFKA-4002: task.open() should be invoked in case that 0 partitions is assigned to task Author: Liquan Pei <[email protected]> Reviewers: Ewen Cheslack-Postava <[email protected]> Closes #1686 from Ishiihara/open-partition Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8d303d0d Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8d303d0d Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8d303d0d Branch: refs/heads/trunk Commit: 8d303d0d389a1dfda93224ae6cc8b426ed6750fb Parents: 778fcd0 Author: Liquan Pei <[email protected]> Authored: Sat Aug 6 21:11:54 2016 -0700 Committer: Ewen Cheslack-Postava <[email protected]> Committed: Sat Aug 6 21:11:54 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/kafka/connect/runtime/WorkerSinkTask.java | 3 --- 1 file changed, 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/8d303d0d/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java ---------------------------------------------------------------------- diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java index fbc2307..2a16934 100644 --- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java +++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java @@ -425,9 +425,6 @@ class WorkerSinkTask extends WorkerTask { } private void openPartitions(Collection<TopicPartition> partitions) { - if (partitions.isEmpty()) - return; - task.open(partitions); }
