kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: KAFKA-4002: task.open() should be invoked in case that 0 partitions is assigned to task
Date Sun, 07 Aug 2016 04:11:40 GMT
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 <liquanpei@gmail.com>

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

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 <liquanpei@gmail.com>
Authored: Sat Aug 6 21:11:54 2016 -0700
Committer: Ewen Cheslack-Postava <me@ewencp.org>
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);
     }
 


Mime
View raw message