You are viewing a plain text version of this content. The canonical link for it is here.
Posted to solr-user@lucene.apache.org by "Anantharaman, Srinatha (Contractor)" <Sr...@comcast.com> on 2017/04/26 18:31:47 UTC
Could not find collection , Error while ingesting to Solr using Flume
and Morphlines
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