Browse Source

MINOR: Fix comment in DistributedHerder

ewencp

Author: Liquan Pei <liquanpei@gmail.com>

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

Closes #1243 from Ishiihara/docs
pull/1220/merge
Liquan Pei 9 years ago committed by Ewen Cheslack-Postava
parent
commit
f213625fc5
  1. 4
      connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java

4
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java

@ -866,8 +866,8 @@ public class DistributedHerder extends AbstractHerder implements Runnable { @@ -866,8 +866,8 @@ public class DistributedHerder extends AbstractHerder implements Runnable {
configBackingStore.putTaskConfigs(connName, taskConfigListAsMap(connName, taskProps));
cb.onCompletion(null, null);
} else {
// We cannot forward the request on the same thread because this reconfiguration can happen in as a
// result of . If we blocked
// We cannot forward the request on the same thread because this reconfiguration can happen as a result of connector
// addition or removal. If we blocked waiting for the response from leader, we may be kicked out of the worker group.
forwardRequestExecutor.submit(new Runnable() {
@Override
public void run() {

Loading…
Cancel
Save