79220049

Date: 2024-11-24 12:26:09
Score: 1.5
Natty:
Report link

It seems that the problem was correlated to this Flink bug: issues.apache.org/jira/browse/FLINK-16686. When i switch TTL mechanism to simple timer-clearing for List State variables (i remove all the TTLs tbh), the pipeline starts working properly and no longer crash. It's strange that the bug is marked as "Not a Priority " and present since Flink 1.8.0.

Reasons:
  • No code block (0.5):
  • Self-answer (0.5):
  • Low reputation (0.5):
Posted by: Baal