# Problem in using JDBC plugin for Elasticsearch **URL:** \ **Category:** Elasticsearch\ **Created:** [March 11, 2015, 3:50pm UTC](https://discuss.elastic.co/t/problem-in-using-jdbc-plugin-for-elasticsearch/22618 "2015-03-11T15:50:12Z")\ **Posts on this page:** 2\ **Page:** 1
**Author:** ![Ali\_Lotfdar](https://avatars.discourse-cdn.com/v4/letter/a/f19dbf/32.png) [@Ali\_Lotfdar](https://discuss.elastic.co/u/Ali_Lotfdar)\ **Post date:** [March 11, 2015, 3:50pm UTC](https://discuss.elastic.co/t/problem-in-using-jdbc-plugin-for-elasticsearch/22618/1 "2015-03-11T15:50:12Z")
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](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](mailto: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](https://groups.google.com/d/msgid/elasticsearch/21ef31b7-4abb-4e67-a317-74e1dfbe3c87%40googlegroups.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [July 6, 2017, 12:27am UTC](https://discuss.elastic.co/t/problem-in-using-jdbc-plugin-for-elasticsearch/22618/2 "2017-07-06T00:27:24Z")