Re: Flink 1.13.6 showing 1.13.5

2022-03-02 Thread Mika Naylor
3-01 at 12.47.16 PM.png] [image: Screen Shot 2022-03-01 at 12.55.37 PM.png] Mika Naylor https://autophagy.io

Re: Upgrade to flink 1.14.2 and using new Data Source and Sink API

2022-01-13 Thread Mika Naylor
cer) After the upgrade, we *keep seeing* these log messages in TM logs Is this OK ? Are we doing something wrong ? BR, Danny [image: image.png] Mika Naylor https://autophagy.io

Re: Cannot consum from Kinesalite using FlinkKinesisConsumer

2021-12-03 Thread Mika Naylor
.0] at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:940) ~[flink-runtime-1.14.0.jar:1.14.0] at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) ~[flink-runtime-1.14.0.jar:1.14.0] at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-runtime-1.14.0.jar:1.14.0] at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_292] -- *Med Vänliga Hälsningar* *Jonas Eyob* Mika Naylor https://autophagy.io