Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SOLR-11234: TriggerListener registration bug.

This commit is contained in:
Andrzej Bialecki 2017-08-14 16:10:37 +02:00
parent 5c691d4542
commit 64c480f3e9
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
solr/core/src/java/org/apache/solr/cloud/autoscaling/AutoScalingHandler.java
View File

@ -556,7 +556,7 @@ public class AutoScalingHandler extends RequestHandlerBase implements Permission
properties.put(AutoScalingParams.TRIGGER, triggerName); properties.put(AutoScalingParams.TRIGGER, triggerName);
properties.put(AutoScalingParams.STAGE, EnumSet.allOf(TriggerEventProcessorStage.class)); properties.put(AutoScalingParams.STAGE, EnumSet.allOf(TriggerEventProcessorStage.class));
AutoScalingConfig.TriggerListenerConfig listener = AutoScalingConfig.TriggerListenerConfig listener =
new AutoScalingConfig.TriggerListenerConfig(CollectionAdminParams.SYSTEM_COLL, properties); new AutoScalingConfig.TriggerListenerConfig(triggerName + CollectionAdminParams.SYSTEM_COLL, properties);
autoScalingConfig = autoScalingConfig.withTriggerListenerConfig(listener); autoScalingConfig = autoScalingConfig.withTriggerListenerConfig(listener);
return autoScalingConfig; return autoScalingConfig;
} }

2
solr/core/src/test/org/apache/solr/cloud/autoscaling/SystemLogListenerTest.java
View File

@ -105,7 +105,7 @@ public class SystemLogListenerTest extends SolrCloudTestCase {
// remove default listener // remove default listener
String removeListenerCommand = "{\n" + String removeListenerCommand = "{\n" +
"\t\"remove-listener\" : {\n" + "\t\"remove-listener\" : {\n" +
"\t\t\"name\" : \".system\"\n" + "\t\t\"name\" : \"node_lost_trigger.system\"\n" +
"\t}\n" + "\t}\n" +
"}"; "}";
req = createAutoScalingRequest(SolrRequest.METHOD.POST, removeListenerCommand); req = createAutoScalingRequest(SolrRequest.METHOD.POST, removeListenerCommand);