From cdd90e0c37a51e7eef2c36111c4ffc8ce56f8613 Mon Sep 17 00:00:00 2001
From: Angel Borroy <angel.borroy@alfresco.com>
Date: Mon, 8 Jun 2020 10:36:23 +0200
Subject: [PATCH] SEARCH-2238: Avoid setting the core name in Floc properties,
 as this provokes the Flocs belonging a group being different and, hence, not
 being grouped by ShardRegistry logic.

---
 .../org/alfresco/solr/tracker/CoreStatePublisher.java    | 9 +++------
 1 file changed, 3 insertions(+), 6 deletions(-)

diff --git a/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/CoreStatePublisher.java b/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/CoreStatePublisher.java
index dda43d880..0b6f32c66 100644
--- a/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/CoreStatePublisher.java
+++ b/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/CoreStatePublisher.java
@@ -41,7 +41,6 @@ import org.alfresco.service.cmr.dictionary.PropertyDefinition;
 import org.alfresco.service.namespace.QName;
 import org.alfresco.solr.AlfrescoCoreAdminHandler;
 import org.alfresco.solr.AlfrescoSolrDataModel;
-import org.alfresco.solr.BoundedDeque;
 import org.alfresco.solr.InformationServer;
 import org.alfresco.solr.NodeReport;
 import org.alfresco.solr.TrackerState;
@@ -203,11 +202,9 @@ public abstract class CoreStatePublisher extends AbstractTracker
 
         HashMap<String, String> propertyBag = new HashMap<>();
         propertyBag.put("coreName", coreName);
-
-        HashMap<String, String> extendedPropertyBag = new HashMap<>(propertyBag);
         updateShardProperty();
 
-        extendedPropertyBag.putAll(docRouter.getProperties(shardProperty));
+        propertyBag.putAll(docRouter.getProperties(shardProperty));
 
         return ShardStateBuilder.shardState()
                 .withMaster(isMaster)
@@ -216,7 +213,7 @@ public abstract class CoreStatePublisher extends AbstractTracker
                 .withLastIndexedChangeSetId(changeSetsTrackerState.getLastIndexedChangeSetId())
                 .withLastIndexedTxCommitTime(transactionsTrackerState.getLastIndexedTxCommitTime())
                 .withLastIndexedTxId(transactionsTrackerState.getLastIndexedTxId())
-                .withPropertyBag(extendedPropertyBag)
+                .withPropertyBag(propertyBag)
                     .withShardInstance()
                         .withBaseUrl(infoSrv.getBaseUrl())
                         .withPort(infoSrv.getPort())
@@ -229,11 +226,11 @@ public abstract class CoreStatePublisher extends AbstractTracker
                                 .withTemplate(shardTemplate)
                                 .withHasContent(transformContent)
                                 .withShardMethod(ShardMethodEnum.getShardMethod(shardMethod))
-                                .withPropertyBag(propertyBag)
                             .endFloc()
                         .endShard()
                     .endShardInstance()
                 .build();
+        
     }
 
     /**