; 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 :
>>>>
>
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.
>
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
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
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)
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
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
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