@@ -163,11 +163,9 @@ public void registerFeatureTypeIfMissingOnAllNodes() {
163163 FeatureType featureType ;
164164 try {
165165 featureType = AutoTaggingRegistry .getFeatureType ("workload_group" );
166- System .out .println ("Already globally registered: " + featureType .getName ());
167166 } catch (ResourceNotFoundException e ) {
168167 featureType = TestWorkloadManagementPlugin .featureType ;
169168 AutoTaggingRegistry .registerFeatureType (featureType );
170- System .out .println ("Registered globally: " + featureType .getName ());
171169 }
172170
173171 for (String node : internalCluster ().getNodeNames ()) {
@@ -176,9 +174,7 @@ public void registerFeatureTypeIfMissingOnAllNodes() {
176174
177175 try {
178176 routingRegistry .getRuleRoutingService (featureType );
179- System .out .println ("Already registered on node: " + node );
180177 } catch (IllegalArgumentException ex ) {
181- System .out .println ("Registering workload_group on node: " + node );
182178 persistenceRegistry .register (featureType , TestWorkloadManagementPlugin .rulePersistenceService );
183179 routingRegistry .register (featureType , TestWorkloadManagementPlugin .ruleRoutingService );
184180 }
@@ -201,18 +197,6 @@ public void testCreateAutoTaggingRule() throws Exception {
201197 Instant .now ().getMillis ()
202198 );
203199 updateWorkloadGroupInClusterState (PUT , workloadGroup );
204- for (String node : internalCluster ().getNodeNames ()) {
205- ClusterService clusterService = internalCluster ().getInstance (ClusterService .class , node );
206- ClusterState state = clusterService .state ();
207- WorkloadGroupMetadata metadata = (WorkloadGroupMetadata ) state .metadata ().custom (WorkloadGroupMetadata .TYPE );
208-
209- if (metadata == null ) {
210- System .out .println ("Node " + node + ": metadata is null" );
211- } else {
212- Set <String > groupIds = metadata .workloadGroups ().keySet ();
213- System .out .println ("Node " + node + ": workload group IDs = " + groupIds );
214- }
215- }
216200
217201 FeatureType featureType = AutoTaggingRegistry .getFeatureType ("workload_group" );
218202 Map <Attribute , Set <String >> attributes = Map .of (RuleAttribute .INDEX_PATTERN , Set .of ("logs-*" ));
0 commit comments