I'm running the following code and getting the RuntimeException "Emit failed due to: org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value." https://dl.dropboxusercontent.com/u/64242132/TestExample.java
Does somebody know what causes it? Another issue is that if the source does not sleep between emits, the program freezes. Peter
