Hi,
Though I see Zookeeper is uploaded with the collection, I get below error while
Ingesting data to Solr using Flume and Morphline.
Kindly let me know if you need more details
017-04-26 18:25:31,767 (SinkRunner-PollingRunner-DefaultSinkProcessor) [DEBUG -
org.kitesdk.morphline.base.AbstractCommand.beforeNotify(AbstractCommand.java:142)]
beforeNotify()
2017-04-26 18:25:31,767 (SinkRunner-PollingRunner-DefaultSinkProcessor) [TRACE
-
org.kitesdk.morphline.base.AbstractCommand.beforeNotify(AbstractCommand.java:140)]
beforeNotify: {lifecycle=[COMMIT_TRANSACTION]}
2017-04-26 18:25:31,768 (SinkRunner-PollingRunner-DefaultSinkProcessor) [DEBUG
-
org.kitesdk.morphline.base.AbstractCommand.beforeNotify(AbstractCommand.java:142)]
beforeNotify()
2017-04-26 18:25:31,768 (SinkRunner-PollingRunner-DefaultSinkProcessor) [TRACE
-
org.kitesdk.morphline.base.AbstractCommand.beforeNotify(AbstractCommand.java:140)]
beforeNotify: {lifecycle=[COMMIT_TRANSACTION]}
2017-04-26 18:25:31,768 (SinkRunner-PollingRunner-DefaultSinkProcessor) [DEBUG
-
org.kitesdk.morphline.base.AbstractCommand.beforeNotify(AbstractCommand.java:142)]
beforeNotify()
2017-04-26 18:25:31,772 (SinkRunner-PollingRunner-DefaultSinkProcessor) [ERROR
-
org.apache.flume.sink.solr.morphline.MorphlineSink.process(MorphlineSink.java:163)]
Morphline Sink SolrSink: Unable to process event from channel FileChannel.
Exception follows.
org.apache.solr.common.SolrException: Could not find collection : esearch
at
org.apache.solr.common.cloud.ClusterState.getCollection(ClusterState.java:162)
at
org.apache.solr.client.solrj.impl.CloudSolrServer.directUpdate(CloudSolrServer.java:305)
at
org.apache.solr.client.solrj.impl.CloudSolrServer.request(CloudSolrServer.java:533)
at
org.apache.solr.client.solrj.request.AbstractUpdateRequest.process(AbstractUpdateRequest.java:124)
at org.apache.solr.client.solrj.SolrServer.add(SolrServer.java:68)
at org.apache.solr.client.solrj.SolrServer.add(SolrServer.java:54)
at
org.apache.solr.morphlines.solr.SolrServerDocumentLoader.loadBatch(SolrServerDocumentLoader.java:91)
at
org.apache.solr.morphlines.solr.SolrServerDocumentLoader.commitTransaction(SolrServerDocumentLoader.java:79)
at
org.apache.solr.morphlines.solr.LoadSolrBuilder$LoadSolr.doNotify(LoadSolrBuilder.java:95)
at
org.kitesdk.morphline.base.AbstractCommand.notify(AbstractCommand.java:132)
at org.kitesdk.morphline.base.Connector.notify(Connector.java:57)
at
org.kitesdk.morphline.base.AbstractCommand.doNotify(AbstractCommand.java:150)
at
org.kitesdk.morphline.base.AbstractCommand.notify(AbstractCommand.java:132)
at org.kitesdk.morphline.base.Connector.notify(Connector.java:57)
at
org.kitesdk.morphline.base.AbstractCommand.doNotify(AbstractCommand.java:150)
at
org.kitesdk.morphline.base.AbstractCommand.notify(AbstractCommand.java:132)
at org.kitesdk.morphline.base.Connector.notify(Connector.java:57)
at
org.kitesdk.morphline.base.AbstractCommand.doNotify(AbstractCommand.java:150)
at
org.kitesdk.morphline.base.AbstractCommand.notify(AbstractCommand.java:132)
at org.kitesdk.morphline.base.Connector.notify(Connector.java:57)
at
org.kitesdk.morphline.base.AbstractCommand.doNotify(AbstractCommand.java:150)
at
org.kitesdk.morphline.base.AbstractCommand.notify(AbstractCommand.java:132)
at org.kitesdk.morphline.base.Connector.notify(Connector.java:57)
at
org.kitesdk.morphline.base.AbstractCommand.doNotify(AbstractCommand.java:150)
at
org.kitesdk.morphline.base.AbstractCommand.notify(AbstractCommand.java:132)
at
org.kitesdk.morphline.base.AbstractCommand.doNotify(AbstractCommand.java:150)
at
org.kitesdk.morphline.base.AbstractCommand.notify(AbstractCommand.java:132)
at
org.kitesdk.morphline.base.Notifications.notify(Notifications.java:96)
at
org.kitesdk.morphline.base.Notifications.notifyCommitTransaction(Notifications.java:61)
at
org.apache.flume.sink.solr.morphline.MorphlineHandlerImpl.commitTransaction(MorphlineHandlerImpl.java:149)
at
org.apache.flume.sink.solr.morphline.MorphlineSink.process(MorphlineSink.java:156)
at
org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
at java.lang.Thread.run(Thread.java:745)
Regards,
~Sri
