root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

MINOR: Fix stage recording in DistributedHerder::addRequest (#16784) 

Reviewers: Greg Harris <greg.harris@aiven.io>
This commit is contained in:
Chris Egerton 2024-08-05 20:36:39 +02:00 committed by GitHub
parent e49c8df1f7
commit 3f3e376797
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
View File

@ -2382,6 +2382,7 @@ public class DistributedHerder extends AbstractHerder implements Runnable {
}
DistributedHerderRequest addRequest(long delayMs, Callable<Void> action, Callback<Void> callback) {
callback.recordStage(tickThreadStage);
DistributedHerderRequest req = new DistributedHerderRequest(time.milliseconds() + delayMs, requestSeqNum.incrementAndGet(), action, callback);
requests.add(req);
// We don't need to synchronize here
@ -2393,7 +2394,6 @@ public class DistributedHerder extends AbstractHerder implements Runnable {
// queue was added
if (peekWithoutException() == req)
member.wakeup();
callback.recordStage(tickThreadStage);
return req;
}