Hi,
up questions
пн, 31 мар. 2025 г., 12:34 Vladislav Keda :
> Hi,
>
> Can you help please with previous questions?
>
> Thanks in advance!
>
> ср, 26 мар. 2025 г., 12:06 Vladislav Keda :
>
>> Hi,
>>
>> We have identified the cause of the problem: ConfigMaps on the Kubernetes
>> cluster were taki
Are you on local FS from checkpoint perspective?
G
On Mon, Apr 7, 2025 at 7:05 PM santosh techie
wrote:
> Hi,
>
> The checkpoint is hardly anything, a few 10s KBs max. Disk is also Ok, On
> further investigation, I suspect is the way exactly once is determined with
> kafka, I see that kafka br
Hi Jean-Marc,
We've just added this as SQL feature [1]. It's possible to
use SavepointLoader from java but it's more complicated.
For the SQL story there is no 1.x backport...
[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/libs/state_processor_api/#metadata
BR,
G
On Fri, Apr 11,
Hi there,
I've got this odd issue with our Flink 1.20 application. We had to make a
change to our savepoints structure (essentially we need to change the keys
we used in the keyBy) so we wrote an application to migrate the savepoint
from the oldkey to the new key.
However when I run the migrated
