TSFenwick commented on code in PR #13670:
URL: https://github.com/apache/druid/pull/13670#discussion_r1091150815
##########
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportLimiterPublisher.java:
##########
@@ -31,13 +31,13 @@
/**
* Limits the number of exceptions that get published to the underlying
delegate publisher. This helps
* in preventing the spam of exceptions from the worker task to the published
source. As such, any implementation
- * of {@link MSQWarningReportPublisher} that is wrapped in this class cannot
be sure that the warning handed off
+ * of {@link MSQWarningPublisher} that is wrapped in this class cannot be sure
that the warning handed off
* is trully published
*/
-public class MSQWarningReportLimiterPublisher implements
MSQWarningReportPublisher
+public class MSQWarningReportLimiterPublisher implements MSQWarningPublisher
Review Comment:
change class to MSQWarningLimiterPublisher
--
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]