0
5 초마다 데이터베이스에 연결할 수있는 스케줄러가있는 강 정의를 만듭니다. 해당 색인 (분석기 필터)에 대한 설정을 추가해야합니다. 인덱스가 열려있을 때는이 작업을 수행 할 수 없습니다. 그래서 많은 스레드에서 제안 된 것처럼 인덱스를 닫았습니다. 일단 닫으면 다음과 같은 예외가 발생합니다.인덱스를 닫을 때 예외가 발생했습니다.
[2014-08-27 17:43:05,236][ERROR][BulkNodeClient ] after bulk [3] error
org.elasticsearch.indices.IndexMissingException: [db2] missing
at org.elasticsearch.cluster.routing.operation.plain.PlainOperationRouting.indexRoutingTable(PlainOperationRouting.java:245)
at org.elasticsearch.cluster.routing.operation.plain.PlainOperationRouting.shards(PlainOperationRouting.java:259)
at org.elasticsearch.cluster.routing.operation.plain.PlainOperationRouting.shards(PlainOperationRouting.java:255)
at org.elasticsearch.cluster.routing.operation.plain.PlainOperationRouting.indexShards(PlainOperationRouting.java:70)
at org.elasticsearch.action.bulk.TransportBulkAction.executeBulk(TransportBulkAction.java:242)
at org.elasticsearch.action.bulk.TransportBulkAction.doExecute(TransportBulkAction.java:153)
at org.elasticsearch.action.bulk.TransportBulkAction.doExecute(TransportBulkAction.java:65)
at org.elasticsearch.action.support.TransportAction.execute(TransportAction.java:65)
at org.elasticsearch.client.node.NodeClient.execute(NodeClient.java:92)
at org.elasticsearch.client.support.AbstractClient.bulk(AbstractClient.java:159)
at org.elasticsearch.action.bulk.BulkProcessor.execute(BulkProcessor.java:294)
at sun.reflect.GeneratedMethodAccessor14.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.xbib.elasticsearch.support.client.bulk.BulkProcessorHelper.flush(BulkProcessorHelper.java:28)
at org.xbib.elasticsearch.support.client.node.BulkNodeClient.flushIngest(BulkNodeClient.java:306)
at org.xbib.elasticsearch.support.client.node.BulkNodeClient.flushIngest(BulkNodeClient.java:37)
at org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth.flush(SimpleRiverMouth.java:179)
at org.xbib.elasticsearch.plugin.feeder.jdbc.JDBCFeeder.executeTask(JDBCFeeder.java:181)
at org.xbib.elasticsearch.plugin.feeder.AbstractFeeder.newRequest(AbstractFeeder.java:363)
at org.xbib.elasticsearch.plugin.feeder.AbstractFeeder.newRequest(AbstractFeeder.java:53)
at org.xbib.pipeline.AbstractPipeline.call(AbstractPipeline.java:87)
at org.xbib.pipeline.AbstractPipeline.call(AbstractPipeline.java:14)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:744)
[2014-08-27 17:43:05,241][ERROR][Feeder ] error while getting next input: client is closed
org.elasticsearch.ElasticsearchIllegalStateException: client is closed
at org.xbib.elasticsearch.support.client.node.BulkNodeClient.waitForResponses(BulkNodeClient.java:313)
at org.xbib.elasticsearch.support.client.node.BulkNodeClient.waitForResponses(BulkNodeClient.java:37)
at org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth.flush(SimpleRiverMouth.java:182)
at org.xbib.elasticsearch.plugin.feeder.jdbc.JDBCFeeder.executeTask(JDBCFeeder.java:181)
at org.xbib.elasticsearch.plugin.feeder.AbstractFeeder.newRequest(AbstractFeeder.java:363)
at org.xbib.elasticsearch.plugin.feeder.AbstractFeeder.newRequest(AbstractFeeder.java:53)
at org.xbib.pipeline.AbstractPipeline.call(AbstractPipeline.java:87)
at org.xbib.pipeline.AbstractPipeline.call(AbstractPipeline.java:14)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:744)
어떻게 해결할 수 있습니까? 무엇이 문제 일 수 있습니까?
강을 다시 시작하는 방법은 무엇입니까? –
내가 함께 일한 유일한 하천은 멈추기 위해 필요한 삭제 작업을 한 다음 다시 처음부터 다시 시작합니다. – Gillespie