599166320 commented on issue #13080: URL: https://github.com/apache/druid/issues/13080#issuecomment-1250101211
> @599166320 , could you please share the json of your rules for this datasource? You can see it in the[ Druid forum](https://www.druidforum.org/t/druid-load-drop-rule/7739). In addition, I found a problem with the following code, and I have repaired it. I ran normally for 2 days ``` //RunRules.run for (Rule rule : rules) { if (rule.appliesTo(segment, now)) { // if ( stats.getGlobalStat( "totalNonPrimaryReplicantsLoaded") >= paramsWithReplicationManager.getCoordinatorDynamicConfig() .getMaxNonPrimaryReplicantsToLoad() && !paramsWithReplicationManager.getReplicationManager().isLoadPrimaryReplicantsOnly() ) { log.info( "Maximum number of non-primary replicants [%d] have been loaded for the current RunRules execution. Only loading primary replicants from here on for this coordinator run cycle.", paramsWithReplicationManager.getCoordinatorDynamicConfig().getMaxNonPrimaryReplicantsToLoad() ); paramsWithReplicationManager.getReplicationManager().setLoadPrimaryReplicantsOnly(true); } stats.accumulate(rule.run(coordinator, paramsWithReplicationManager, segment)); foundMatchingRule = true; break; } } ``` -- 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]
