Hello All,
I am going to use this plugin for transferring some data from mysql to
elasticsearch.
I followed all steps in
"https://github.com/jprante/elasticsearch-river-jdbc" but I encounter with
error(the log is in below).
Plugin version: 4.0.10
ElasticSearch Version: 1.4.4
Thank to let me know what I have to to to solve this problem.
[2015-03-11 11:46:30,877][INFO ][river.jdbc.JDBCRiver ] started river
instance for single run
[2015-03-11 11:47:01,118][ERROR][river.jdbc.BulkNodeClient] cluster state
is RED and not YELLOW, cowardly refusing to continue with operations
java.io.IOException: cluster state is RED and not YELLOW, cowardly refusing
to continue with operations
at
org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper.waitForCluster(ClientHelper.java:85)
at
org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient.waitForCluster(BulkNodeClient.java:411)
at
org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient.newClient(BulkNodeClient.java:205)
at
org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiver$1.create(JDBCRiver.java:237)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth.setIngestFactory(SimpleRiverMouth.java:88)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth.setIngestFactory(SimpleRiverMouth.java:45)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow.createRiverMouth(SimpleRiverFlow.java:304)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow.beforeFetch(SimpleRiverFlow.java:184)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow.execute(SimpleRiverFlow.java:148)
at
org.xbib.elasticsearch.plugin.jdbc.RiverPipeline.request(RiverPipeline.java:88)
at
org.xbib.elasticsearch.plugin.jdbc.RiverPipeline.call(RiverPipeline.java:66)
at
org.xbib.elasticsearch.plugin.jdbc.RiverPipeline.call(RiverPipeline.java:30)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
[2015-03-11 11:47:02,603][ERROR][river.jdbc.SimpleRiverFlow] client is
closed
org.elasticsearch.ElasticsearchIllegalStateException: client is closed
at
org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient.flushIngest(BulkNodeClient.java:347)
at
org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient.flushIngest(BulkNodeClient.java:53)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth.flush(SimpleRiverMouth.java:284)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth.afterFetch(SimpleRiverMouth.java:120)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow.afterFetch(SimpleRiverFlow.java:270)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow.execute(SimpleRiverFlow.java:151)
at
org.xbib.elasticsearch.plugin.jdbc.RiverPipeline.request(RiverPipeline.java:88)
at
org.xbib.elasticsearch.plugin.jdbc.RiverPipeline.call(RiverPipeline.java:66)
at
org.xbib.elasticsearch.plugin.jdbc.RiverPipeline.call(RiverPipeline.java:30)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
[2015-03-11 11:47:02,653][ERROR][river.jdbc.RiverPipeline ]
org.elasticsearch.ElasticsearchIllegalStateException: client is closed
java.io.IOException: org.elasticsearch.ElasticsearchIllegalStateException:
client is closed
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource.fetch(SimpleRiverSource.java:353)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow.fetch(SimpleRiverFlow.java:220)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow.execute(SimpleRiverFlow.java:149)
at
org.xbib.elasticsearch.plugin.jdbc.RiverPipeline.request(RiverPipeline.java:88)
at
org.xbib.elasticsearch.plugin.jdbc.RiverPipeline.call(RiverPipeline.java:66)
at
org.xbib.elasticsearch.plugin.jdbc.RiverPipeline.call(RiverPipeline.java:30)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.elasticsearch.ElasticsearchIllegalStateException: client is
closed
at
org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient.bulkIndex(BulkNodeClient.java:269)
at
org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient.bulkIndex(BulkNodeClient.java:53)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth.index(SimpleRiverMouth.java:236)
at
org.xbib.elasticsearch.plugin.jdbc.util.RiverMouthKeyValueStreamListener.end(RiverMouthKeyValueStreamListener.java:53)
at
org.xbib.elasticsearch.plugin.jdbc.util.RiverMouthKeyValueStreamListener.end(RiverMouthKeyValueStreamListener.java:26)
at
org.xbib.elasticsearch.plugin.jdbc.util.PlainKeyValueStreamListener.values(PlainKeyValueStreamListener.java:139)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource.processRow(SimpleRiverSource.java:824)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource.nextRow(SimpleRiverSource.java:777)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource.merge(SimpleRiverSource.java:510)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource.execute(SimpleRiverSource.java:405)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource.fetch(SimpleRiverSource.java:332)
... 9 more
[2015-03-11 11:47:02,661][INFO ][river.jdbc.RiverMetrics ] pipeline
org.xbib.elasticsearch.plugin.jdbc.RiverPipeline@261cb76e complete: river
jdbc/myqivosql metrics: 1 rows, 0.03146519080867322 mean, (0.0 0.0 0.0),
ingest metrics: elapsed 31 seconds, 0.0 bytes bytes, 0.0 bytes avg, 0 MB/s
[2015-03-11 11:47:02,661][ERROR][river.jdbc.RiverThread ]
org.elasticsearch.ElasticsearchIllegalStateException: client is closed
java.util.concurrent.ExecutionException:
org.elasticsearch.ElasticsearchIllegalStateException: client is closed
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at
org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.SimplePipelineExecutor.waitFor(SimplePipelineExecutor.java:124)
at
org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.MetricSimplePipelineExecutor.waitFor(MetricSimplePipelineExecutor.java:61)
at
org.xbib.elasticsearch.plugin.jdbc.RiverRunnable.run(RiverRunnable.java:123)
at java.lang.Thread.run(Thread.java:745)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.elasticsearch.ElasticsearchIllegalStateException: client is
closed
at
org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient.flushIngest(BulkNodeClient.java:347)
at
org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient.flushIngest(BulkNodeClient.java:53)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth.flush(SimpleRiverMouth.java:284)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth.shutdown(SimpleRiverMouth.java:138)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext.release(SimpleRiverContext.java:435)
at
org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext.release(SimpleRiverContext.java:42)
at
org.xbib.elasticsearch.plugin.jdbc.RiverPipeline.call(RiverPipeline.java:70)
at
org.xbib.elasticsearch.plugin.jdbc.RiverPipeline.call(RiverPipeline.java:30)
... 4 more
Regards,
Ali
--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/elasticsearch/21ef31b7-4abb-4e67-a317-74e1dfbe3c87%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.