Re: Issue with running Flink Python jobs on cluster

2016-07-16 Thread Geoffrey Mon
The Java program I used to test DistributedCache was faulty since it actually created the cache from files on the machine on which the program was running (i.e. the worker node). I tried implementing a cluster again, this time using two actual machines instead of virtual machines. I found the same

Error using S3a State Backend: Window Operators sending directory instead of fully qualified file?

2016-07-16 Thread Clifford Resnick
Using Flink 1.1-SNAPSHOT, Hadoop-aws 2.6.4 The error I’m getting is : 11:05:44,425 ERROR org.apache.flink.streaming.runtime.tasks.StreamTask - Caught exception while materializing asynchronous checkpoints. com.amazonaws.AmazonClientException: Unable to calculate MD5 hash: /var/folders