Created
August 3, 2016 16:25
-
-
Save srijiths/e0d5cd1cc2e499681b63736cd22f3eaa to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{172.30.1.168}{172.30.1.168:9300}]] | |
| at org.elasticsearch.client.transport.TransportClientNodesService.ensureNodesAreAvailable(TransportClientNodesService.java:290) | |
| at org.elasticsearch.client.transport.TransportClientNodesService.execute(TransportClientNodesService.java:207) | |
| at org.elasticsearch.client.transport.support.TransportProxyClient.execute(TransportProxyClient.java:55) | |
| at org.elasticsearch.client.transport.TransportClient.doExecute(TransportClient.java:288) | |
| at org.elasticsearch.client.support.AbstractClient.execute(AbstractClient.java:359) | |
| at org.elasticsearch.client.support.AbstractClient.bulk(AbstractClient.java:436) | |
| at org.elasticsearch.action.bulk.Retry$AbstractRetryHandler.execute(Retry.java:219) | |
| at org.elasticsearch.action.bulk.Retry.withAsyncBackoff(Retry.java:72) | |
| at org.elasticsearch.action.bulk.BulkRequestHandler$AsyncBulkRequestHandler.execute(BulkRequestHandler.java:123) | |
| at org.elasticsearch.action.bulk.BulkProcessor.execute(BulkProcessor.java:312) | |
| at org.elasticsearch.action.bulk.BulkProcessor.executeIfNeeded(BulkProcessor.java:303) | |
| at org.elasticsearch.action.bulk.BulkProcessor.internalAdd(BulkProcessor.java:285) | |
| at org.elasticsearch.action.bulk.BulkProcessor.add(BulkProcessor.java:268) | |
| at org.elasticsearch.action.bulk.BulkProcessor.add(BulkProcessor.java:264) | |
| at org.elasticsearch.action.bulk.BulkProcessor.add(BulkProcessor.java:250) | |
| at com.cts.peg.iot.processor.flink.db.ElasticsearchIndexer.indexOutputToEs(ElasticsearchIndexer.java:69) | |
| at com.cts.peg.iot.processor.flink.db.ElasticsearchIndexer.flatMap(ElasticsearchIndexer.java:62) | |
| at com.cts.peg.iot.processor.flink.db.ElasticsearchIndexer.flatMap(ElasticsearchIndexer.java:18) | |
| at org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:48) | |
| at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:351) | |
| at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:337) | |
| at org.apache.flink.streaming.api.operators.StreamSource$NonTimestampContext.collect(StreamSource.java:158) | |
| at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09$ConsumerThread.run(FlinkKafkaConsumer09.java:473) | |
| 2016-08-03 15:25:37,392 ERROR com.cts.peg.iot.processor.flink.db.RedisLookup - NoNodeAvailableException[None of the configured nodes are available: [{#transport#-1}{172.30.1.168}{172.30.1.168:9300}]] | |
| 2016-08-03 15:25:37,482 WARN org.elasticsearch.client.transport - [Hobgoblin] node {#transport#-1}{172.30.1.168}{172.30.1.168:9300} not part of the cluster Cluster [elasticsearch], ignoring... | |
| 2016-08-03 15:25:37,482 WARN org.elasticsearch.client.transport - [Rax] node {#transport#-1}{172.30.1.168}{172.30.1.168:9300} not part of the cluster Cluster [elasticsearch], ignoring... | |
| 2016-08-03 15:25:37,506 WARN org.elasticsearch.client.transport - [Amber Hunt] node {#transport#-1}{172.30.1.168}{172.30.1.168:9300} not part of the cluster Cluster [elasticsearch], ignoring... | |
| 2016-08-03 15:25:37,525 WARN org.elasticsearch.client.transport - [Pasco] node {#transport#-1}{172.30.1.168}{172.30.1.168:9300} not part of the cluster Cluster [elasticsearch], ignoring... |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Hi I'm having same trouble here, please help out