Re: cluster execution

xD… a simple "hdfs dfs -chmod -R 777 /users" fixed it! > Am 01.02.2016 um 12:17 schrieb Till Rohrmann : > > Hi Lydia, > > I looks like that. I guess you should check your hdfs access rights. > > Cheers, > Till > > On Mon, Feb 1, 2016 at 11:28 AM, Lydia Ickler

Re: cluster execution

Hi Lydia, I looks like that. I guess you should check your hdfs access rights. Cheers, Till On Mon, Feb 1, 2016 at 11:28 AM, Lydia Ickler wrote: > Hi Till, > > thanks for your reply! > I tested it with the Wordcount example. > Everything works fine if I run the command: > ./flink run -p 3 /hom

Re: cluster execution

Hi Till, thanks for your reply! I tested it with the Wordcount example. Everything works fine if I run the command: ./flink run -p 3 /home/flink/examples/WordCount.jar Then the program gets executed by my 3 workers. If I want to save the output to a file: ./flink run -p 3 /home/flink/examples/Wor

Re: cluster execution

Hi Lydia, what do you mean with master? Usually when you submit a program to the cluster and don’t specify the parallelism in your program, then it will be executed with the parallelism.default value as parallelism. You can specify the value in your cluster configuration flink-config.yaml file. Al

Re: Cluster Execution - log

Hi Stephan, yes, now it is solved. I was running an older version of the client by mistake. Thanks Juan On Thu, 2015-07-23 at 15:31 +0200, Stephan Ewen wrote: > Hi! > > > Seems that you have different versions of the code running locally and > on the cluster. Is it possible that you did a co

Re: Cluster Execution - log

Hi! Seems that you have different versions of the code running locally and on the cluster. Is it possible that you did a code update locally (client), and forgot to update the cluster (or the other way around)? Greetings, Stephan On Thu, Jul 23, 2015 at 3:10 PM, Juan Fumero < juan.jose.fumero.a

Re: Cluster execution -jar files-

As the JavaDoc explains: >* @param jarFiles The JAR files with code that needs to be shipped to > the cluster. If the program uses >* user-defined functions, user-defined input formats, > or any libraries, those must be >* provided in the J

Re: Cluster execution -jar files-

Missing reference: [1] https://ci.apache.org/projects/flink/flink-docs-release-0.9/apis/cluster_execution.html On Don, 2015-07-16 at 16:04 +0200, Juan Fumero wrote: > Hi, > I would like to use the createRemoteEnvironment to run the application > in a cluster and I have some questions. Followin