This is an automated email from the ASF dual-hosted git repository.
jonwei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git
The following commit(s) were added to refs/heads/master by this push:
new 255214c correct variable name in KafkaSupervisor (#6354)
255214c is described below
commit 255214cbe6f7f16d677ef9469a4dc84d03bc9bc4
Author: QiuMM <[email protected]>
AuthorDate: Fri Sep 21 07:22:03 2018 +0800
correct variable name in KafkaSupervisor (#6354)
---
.../apache/druid/indexing/kafka/supervisor/KafkaSupervisor.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisor.java
b/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisor.java
index c3a94a4..07e98f3 100644
---
a/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisor.java
+++
b/extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisor.java
@@ -1138,11 +1138,11 @@ public class KafkaSupervisor implements Supervisor
}
);
taskGroupsToVerify.put(taskGroupId, taskGroup);
- final TaskData prevTaskGroup =
taskGroup.tasks.putIfAbsent(taskId, new TaskData());
- if (prevTaskGroup != null) {
+ final TaskData prevTaskData =
taskGroup.tasks.putIfAbsent(taskId, new TaskData());
+ if (prevTaskData != null) {
throw new ISE(
- "WTH? a taskGroup[%s] already exists for new
task[%s]",
- prevTaskGroup,
+ "WTH? a taskData[%s] already exists for new
task[%s]",
+ prevTaskData,
taskId
);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
