Skip to content

Commit 270349c

Browse files
authored
[controller] add cluster name to the 'Venice-Admin-Execution-Task' th… (#684)
[controller] add cluster name to the 'Venice-Admin-Execution-Task' threads In controller, each cluster has one corresponding AdminConsumptionTask and multiple 'Venice-Admin-Execution-Task' to consume the admin messages and then execute the admin operations. Today, it is not easy to differentiate which cluster one execution task belongs to, if one analyze controller logs or Java heap dump. This change appends the cluster name to the existing thread name prefix to make it distinguishable.
1 parent 486cb94 commit 270349c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

services/venice-controller/src/main/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTask.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -291,7 +291,7 @@ public AdminConsumptionTask(
291291
60,
292292
TimeUnit.SECONDS,
293293
new LinkedBlockingQueue<>(MAX_WORKER_QUEUE_SIZE),
294-
new DaemonThreadFactory("Venice-Admin-Execution-Task"));
294+
new DaemonThreadFactory(String.format("Venice-Admin-Execution-Task-%s", clusterName)));
295295
this.undelegatedRecords = new LinkedList<>();
296296
this.stats.setAdminConsumptionFailedOffset(failingOffset);
297297
this.pubSubTopicRepository = pubSubTopicRepository;

0 commit comments

Comments
 (0)