Hi
We've got a situation where we're merging several Kafka streams and for
certain streams, we want to retain up to 6 days of history. We're trying to
figure out how we can migrate savepoint data between application updates
when the data type for a certain state buffer updates.
Let's assume that
Gordon
Thanks for the detailed response. I have verified your assumption and that
is, unfortunately, the case.
I also looked into creating a custom Kryo serializer but I got stuck on
serializing arrays of complex types. It seems like this isn't trivial at all
with Kryo.
As an alternative, I've b
Hi
We're running 3 job managers in high availability cluster mode backed by
OpenStack/Openshift. We're currently exposing all 3 job managers using 3
different routes (flink-1.domain.tld, flink-2.domain.tld,
flink-3.domain.tld). When accessing the route for a job manager which isn't
the leader it a
Chesnay, your solution is definitely the best approach. I was already
wondering why the decision was made to only support the UI through the
leading job manager only.
Jürgen, I don't think that your solution will work in our setup. We're
currently running 3 services, one for each job manager. We n
Hi Gordon
I've been looking into creating a custom AvroSerializer without Kryo which
would support Avro schemas and I'm starting to wonder if this is actually
the most straightforward way to do it.
If I extend a class from TypeSerializer I would also need to implement a
TypeInformation class to
