Hadoop/Yarn distributed shell example
It turned out that the main problem with my own code was that I naively instantiated the Configuration
class, instead of instantiating YarnConfiguration
. This way, the yarn config files were not read, and it tried to contact the servers on their default ports - which don't agree with my settings.
The same bug seems to be present in the distributedshell
example.