flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Akshay Iyangar <aiyan...@godaddy.com>
Subject Flink's status for Unbounded source goes to Finish after upgrade to 1.10
Date Fri, 12 Jun 2020 04:20:36 GMT
Hi

We recently decided to upgrade our Flink cluster from 1.8 to 1.10.

Post the upgrade we see issues where our pipelines which read data from unbounded sources
(kinesis) go to FINISH state. I’m a little confused to see why that would be happening especially
if it is an unbounded source?

Also to give some context mostly all the pipelines are written in Beam and run on Flink.


SNAPS
FLINK 1.8
[cid:image001.png@01D64036.113CB090]


Flink 1.10
[cid:image002.png@01D64036.113CB090]


Any idea why this might be happening?


Mime
View raw message