long to process the buffered data. You could try to
>enable unalign checkpoint (via configuration
>`execution.checkpointing.unaligned.enabled` which is false by default)
>and lower the PyFlink bundle size (via configuration
>python.fn-execution.bundle.size which is 1000 by de
Hello,
I tried the configuration you mentioned, but it doesn't seem to work. Still,
thank you for your response!
At 2025-05-13 17:54:03, "Sharath" wrote:
>Hello,
>
>Have you tried enabling the buffer debloating feature to improve checkpoint
>times? Refer taskmanager.network.memor
Hirson Zhang created FLINK-37357:
Summary: Migrating conversion logic to SqlNodeConverters
Key: FLINK-37357
URL: https://issues.apache.org/jira/browse/FLINK-37357
Project: Flink
Issue Type
