Re: Test example and lambdas

2017-08-05 Thread Егор Литвиненко
> No errors, and no data in table. 2017-08-05 14:49 GMT+03:00 Егор Литвиненко : > 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/or

Test example and lambdas

2017-08-05 Thread Егор Литвиненко
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 intent

Questions

2017-07-26 Thread Егор Литвиненко
Hi Is there a way to process mapping errors in Flink? For example when string is valid double write in one table, otherwise in another? If not, what problems you see reffered to this opportunity and if I will make PR, where I should start to implenent this feature? I saw Tuple1, 2, etc. Many meth