No errors, and no
data in table.

2017-08-05 14:49 GMT+03:00 Егор Литвиненко <e.v.litvinenko.1@gmail.com>:
Hi

I try to test Flink and have a problems.
Why this example doesn't work - https://github.com/egorlitvinenko/testparsing/blob/master/test-flink/src/main/java/org/egorlitvinenko/testflink/StreamingJob9C.java
Logs - https://pastebin.com/iuBZhfeG
No errors, and no 

One more question. Examples intentionally use anonymous classes, instead of lambdas. Because with lambda it also doesn't work. I did small investigation and found out that Flink has different processing for lambdas. And in one moment when Flink processes types, they are empty.  Do you have full lambdas support?

In best regards, Egor Litvinenko.