-
Notifications
You must be signed in to change notification settings - Fork 3.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Improve logging to include taskId in handoff notifier thread #17185
Conversation
* Add indexTaskId to coordinator handoff thread name * Add indexTaskId to coordinator handoff thread name contd. * Fix tests
@hardikbajaj , do you see this while running an indexer node? Because with middle managers, each task would have its separate log file. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Left some suggestions.
server/src/main/java/org/apache/druid/segment/handoff/SegmentHandoffNotifierFactory.java
Outdated
Show resolved
Hide resolved
...r/src/main/java/org/apache/druid/segment/handoff/CoordinatorBasedSegmentHandoffNotifier.java
Outdated
Show resolved
Hide resolved
@kfaraz I'm not sure on if each task has separate logfile on indexers, I'll check that ( it might be ) |
No, Indexers currently don't have a separate log file for each task, only Middle Managers do. |
* Address comments * Check style
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM, thanks for the logging improvement, @hardikbajaj !
@hardikbajaj , there seems to be insufficient code coverage for the above classes. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Left some suggestions to fix coverage issue.
...xing-service/src/main/java/org/apache/druid/indexing/common/task/AbstractBatchIndexTask.java
Outdated
Show resolved
Hide resolved
...xing-service/src/main/java/org/apache/druid/indexing/common/task/AbstractBatchIndexTask.java
Outdated
Show resolved
Hide resolved
…pache#17185) (#73) * Improve logging to include taskId in segment handoff notifier thread (apache#17185) * Fix dependencies effecting cherry-pick
…pache#17185) (#233) * Improve logging to include taskId in segment handoff notifier thread (apache#17185) * Fix dependencies effecting cherry-pick
Fixes Logging improvements.
Description
For each indexing task running on a Worker node, Coordinator handoff notifier thread is executed and they have same name format
"coordinator_handoff_scheduled_0"
So if a worker is RUNNING 3 tasks, all three will show logs like
At times, there is a need to check which indexTask segments are waiting for handoff while debugging.
This backward compatible change will improve logging and Decorate the thread executor service name withindexTaskId
.Improve logging by including taskId in coordinator handoff notifier logs.
Fixed the bug ...
Renamed the class ...
Added a forbidden-apis entry ...
Release note
Key changed/added classes in this PR
MyFoo
OurBar
TheirBaz
This PR has: