AMBARI-17521. If Solr is configured to use implicit routing, then replicationFactor is ignored (Bosco Durai via oleewere)

ambari-logsearch/ambari-logsearch-logfeeder/src/main/resources/logfeeder.properties

@@ -17,7 +17,7 @@ logfeeder.checkpoint.folder=
 logfeeder.metrics.collector.hosts=
 
 #filter config
-logfeeder.log.filter.enable=true
+logfeeder.log.filter.enable=false
 logfeeder.solr.config.interval=5
 logfeeder.solr.zk_connect_string=
 logfeeder.solr.url=

ambari-logsearch/ambari-logsearch-logfeeder/src/main/scripts/run.sh

@@ -64,7 +64,7 @@ LOGFEEDER_GC_OPTS="-XX:+PrintGCDetails -XX:+PrintGCDateStamps -Xloggc:$LOGFEEDER
 
 #JMX="-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.port=2098"
 
-if [ $LOGFEEDER_SSL = "true" ]; then
+if [ "$LOGFEEDER_SSL" = "true" ]; then
   LOGFEEDER_JAVA_OPTS="$LOGFEEDER_JAVA_OPTS -Djavax.net.ssl.keyStore=$LOGFEEDER_KEYSTORE_LOCATION -Djavax.net.ssl.keyStoreType=$LOGFEEDER_KEYSTORE_TYPE -Djavax.net.ssl.keyStorePassword=$LOGFEEDER_KEYSTORE_PASSWORD -Djavax.net.ssl.trustStore=$LOGFEEDER_TRUSTSTORE_LOCATION -Djavax.net.ssl.trustStoreType=$LOGFEEDER_TRUSTSTORE_TYPE -Djavax.net.ssl.trustStorePassword=$LOGFEEDER_TRUSTSTORE_PASSWORD"
 fi
 

ambari-logsearch/ambari-logsearch-portal/src/main/java/org/apache/ambari/logsearch/dao/SolrDaoBase.java

@@ -248,7 +248,7 @@ public abstract class SolrDaoBase {
           numberOfShards, replicationFactor, allCollectionList);
       } else {
         result = setupCollectionsWithImplicitRouting(splitMode,
-          configName, numberOfShards, allCollectionList);
+          configName, numberOfShards, replicationFactor, allCollectionList);
       }
     } catch (Exception ex) {
       logger.error("Error creating collection. collectionName="
@@ -279,16 +279,16 @@ public abstract class SolrDaoBase {
   }
 
   public boolean setupCollectionsWithImplicitRouting(String splitMode,
-                                                     String configName, int numberOfShards,
+                                                     String configName, int numberOfShards, int replicationFactor,
                                                      List<String> allCollectionList) throws Exception {
     logger.info("setupCollectionsWithImplicitRouting(). collectionName="
       + collectionName + ", numberOfShards=" + numberOfShards);
     return createCollectionWithImplicitRoute(collectionName, configName,
-      numberOfShards, allCollectionList);
+      numberOfShards, replicationFactor, allCollectionList);
   }
 
   public boolean createCollectionWithImplicitRoute(String colName,
-                                                   String configName, int numberOfShards,
+                                                   String configName, int numberOfShards, int replicationFactor,
                                                    List<String> allCollectionList) throws SolrServerException,
     IOException {
 
@@ -310,7 +310,6 @@ public abstract class SolrDaoBase {
     if (!allCollectionList.contains(colName)) {
       logger.info("Creating collection " + colName + ", shardsList="
         + shardsList + ", solrDetail=" + solrDetail);
-      int replicationFactor = 1;
       CollectionAdminRequest.Create collectionCreateRequest = new CollectionAdminRequest.Create();
       collectionCreateRequest.setCollectionName(colName);
       collectionCreateRequest.setRouterName("implicit");