Hi,
Row is very special data type, because Flink cannot extract the field
types automatically based on Java generics. By default it is serialized
by Kryo, you need to specify the field types using
Typles.ROW(Types.STRING, ...) and pass this information in your
`.returns()` methods instead of
> 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/org/egorlitvinenko/testflink/StreamingJob9C.
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
