[FLINK-1265] Fix user classloader bug for registerInputOutput() method
[Flink-1262] inconsistency between CsvReader.java and TupleGenerator.java

This closes #222
[FLINK-1264] [compiler] Properly forward custom partitioners to the runtime
[FLINK-820] [compiler] Support for disconnected data flows