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
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