Running Custom Code on Cluster

[Will Walters]

Hello,
I've recently been successful running the Quickstart on my cluster (in Flink 
through Yarn on Hadoop). However, I'm unable to run my own code. Adding my own 
java files alongside the default WordCount files causes submission of both mine 
and the default files to fail. Trying to run through a compiled version of the 
master Beam fails similarly. Does anyone have any advice on how to approach or 
solve this problem?
Thank you,Will.