rohangarg commented on a change in pull request #11662:
URL: https://github.com/apache/druid/pull/11662#discussion_r704553333
##########
File path:
extensions-contrib/moving-average-query/src/main/java/org/apache/druid/query/movingaverage/MovingAverageQueryModule.java
##########
@@ -58,4 +68,25 @@ public void configure(Binder binder)
)));
}
+ @Provides
+ @LazySingleton
+ @Named("movingAverage")
+ public QuerySegmentWalker createQueryWalker(@Self Set<NodeRole> nodeRoles,
Injector injector)
+ {
+ if (!nodeRoles.contains(NodeRole.BROKER)) {
Review comment:
Yes, I tested the current fix with quickstart which contains all worker
types. Tested the following on quickstart :
1. Clean startup on all workers
2. Simple ingestion job
3. Simple queries
4. Moving average queries as mentioned in
https://druid.apache.org/docs/latest/development/extensions-contrib/moving-average-query.html
Please let me know incase anything else would be useful as well
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
