Re: Local Cluster have problem with connect to elasticsearch

2016-05-12 Thread rafal green
; From your description, it seems like Flink is complaining because it >>>> cannot >>>> access the Elasticsearch API related dependencies as well. You'd also >>>> have >>>> to include the following into your Maven build, under : >>>> >

Re: Local Cluster have problem with connect to elasticsearch

2016-05-12 Thread rafal green
ion -Delasticsearch.version=2.3.2, and use the newly build connector > jar, following the same method mentioned above? > > Hope this helps! > > Cheers, > Gordon > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Local-Cluster-have-problem-with-connect-to-elasticsearch-tp6788p6838.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Re: Local Cluster have problem with connect to elasticsearch

2016-05-11 Thread Tzu-Li (Gordon) Tai
version=2.3.2, and use the newly build connector jar, following the same method mentioned above? Hope this helps! Cheers, Gordon -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Local-Cluster-have-problem-with-connect-to-elasticsearch-tp6788p6838.h

Re: Local Cluster have problem with connect to elasticsearch

2016-05-11 Thread rafal green
Thanks a lot for many answer :) Last time I write this email cause I don't understand what is the difference between LOCAL cluster (one node) and IntelliJ IDEA. Now I know :P https://ci.apache.org/projects/flink/flink-docs-master/apis/cluster_execution.html If you read this *"Linking with

Re: Local Cluster have problem with connect to elasticsearch

2016-05-11 Thread Martin Neumann
Hi, Are you sure the elastic cluster is running correctly? Open a browser and try 127.0.0.1:9200 that should give you the overview of the cluster. If you don't get it there is something wrong with the setup. Its also a good way to double check the cluster.name (I got that wrong more than once)

Re: Local Cluster have problem with connect to elasticsearch

2016-05-11 Thread Stephan Ewen
Seeing how you put a loopback address into the transport addresses, are you sure that an ElasticSearch node runs on every machine? On Wed, May 11, 2016 at 7:41 PM, Stephan Ewen wrote: > ElasticSearch is basically saying that it cannot connect. > > Is it possible that the

Re: Local Cluster have problem with connect to elasticsearch

2016-05-11 Thread Stephan Ewen
ElasticSearch is basically saying that it cannot connect. Is it possible that the configuration of elastic may be incorrect, or some of the ports may be blocked? On Mon, May 9, 2016 at 7:05 PM, rafal green wrote: > Dear Sir or Madam, > > Can you tell me why I have a

Local Cluster have problem with connect to elasticsearch

2016-05-09 Thread rafal green
Dear Sir or Madam, Can you tell me why I have a problem with elasticsearch in local cluster? I analysed this example: https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/connectors/elasticsearch2.html My flink and elasticsearch config are default (only I change node.name to