Nope - thanks for advice ;) I will try that tomorrow 2016-05-20 11:24 GMT+02:00 Ufuk Celebi <u...@apache.org>:
> I would suggest to set the log level to DEBUG and check the logs why > the client can not connect to your elastic search cluster. Did you try > that? > > On Mon, May 9, 2016 at 3:54 PM, rafal green <rafal.gree...@gmail.com> > wrote: > > 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 > > "node-1") > > > > This example run on my IntelliJIdea 15 but on local cluster I have a > > problem. Of course WordCount and SocketTextStreamWordCount works fine. > > > > > > I spend 2 days to try find solution (With uncle google ;) ) but It's not > > easy > > > > val config = new java.util.HashMap[String, String] > > config.put("bulk.flush.max.actions", "1") > > config.put("cluster.name", "elasticsearch") > > config.put("path.home", > > > "/media/user/e5e05ab5-28f3-4cee-a57c-444e32b99f04/thesis/elasticsearch-2.3.2") > > > > val transports = new util.ArrayList[InetSocketAddress] > > transports.add(new > > InetSocketAddress(InetAddress.getByName("127.0.0.1"),9300)) > > > > > > > > Error output: > > > > java.lang.RuntimeException: Client is not connected to any Elasticsearch > > nodes! > > at > > > org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink.open(ElasticsearchSink.java:172) > > at > > > org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:38) > > at > > > org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:91) > > at > > > org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:317) > > at > > > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:215) > > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:579) > > at java.lang.Thread.run(Thread.java:745) > > > > 05/08/2016 22:57:02 Job execution switched to status FAILING. > > java.lang.RuntimeException: Client is not connected to any Elasticsearch > > nodes! > > at > > > org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink.open(ElasticsearchSink.java:172) > > at > > > org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:38) > > at > > > org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:91) > > at > > > org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:317) > > at > > > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:215) > > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:579) > > at java.lang.Thread.run(Thread.java:745) > > 05/08/2016 22:57:02 Job execution switched to status FAILED. > > > > ------------------------------------------------------------ > > The program finished with the following exception: > > > > org.apache.flink.client.program.ProgramInvocationException: The program > > execution failed: Job execution failed. > > at org.apache.flink.client.program.Client.runBlocking(Client.java:381) > > at org.apache.flink.client.program.Client.runBlocking(Client.java:355) > > at > > > org.apache.flink.streaming.api.environment.StreamContextEnvironment.execute(StreamContextEnvironment.java:65) > > at > > > org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.scala:541) > > at com.pl.greeny.flink.TwitterAnalysis$.main(TwitterAnalysis.scala:69) > > at com.pl.greeny.flink.TwitterAnalysis.main(TwitterAnalysis.scala) > > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > > at > > > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > > at > > > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > > at java.lang.reflect.Method.invoke(Method.java:498) > > at > > > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:505) > > at > > > org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:403) > > at org.apache.flink.client.program.Client.runBlocking(Client.java:248) > > at > > > org.apache.flink.client.CliFrontend.executeProgramBlocking(CliFrontend.java:860) > > at org.apache.flink.client.CliFrontend.run(CliFrontend.java:327) > > at > > > org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1187) > > at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1238) > > Caused by: org.apache.flink.runtime.client.JobExecutionException: Job > > execution failed. > > at > > > org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply$mcV$sp(JobManager.scala:807) > > at > > > org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:753) > > at > > > org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:753) > > at > > > scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24) > > at > > > scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24) > > at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41) > > at > > > akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401) > > at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > > at > > > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > > at > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > > at > > > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > Caused by: java.lang.RuntimeException: Client is not connected to any > > Elasticsearch nodes! > > at > > > org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSink.open(ElasticsearchSink.java:172) > > at > > > org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:38) > > at > > > org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:91) > > at > > > org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:317) > > at > > > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:215) > > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:579) > > at java.lang.Thread.run(Thread.java:745) > > > > > > Best regards, > > Rafal Greeny >
