...btw I found this (in folder:
"flink/flink-streaming-connectors/flink-connector-elasticsearch2.pom.xml")
:
2.2.1
I change it to 2.3.2 version and of course rebuild with that command "mvn
clean install -DskipTests"
...but nothing is changed.
2016-05-12 22:39 GMT+02:00 rafal green :
> Sorr
Hi Gordon,
Thanks for advice - it's work perfect but only in elasticsearch case.
This pom version works for elasticsearch 2.2.1.
org.apache.flink
flink-connector-elasticsearch2_${scala.version}
1.1-SNAPSHOT
jar
false
${project.build.directory}/classes
org/apache/flink/**
Hi Rafal,
>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 :
org.elasticsearch
elasticsearch
2.3.2
jar
false
${proj
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 modul
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)
I
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 configuration of elastic
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 problem with elasticsearch
