Hello Ivan!
Could you please create a JIRA issue out of this?
That seem the proper place where to discuss this.
It seems a bug as the two versions of the code you posted look identical, and
the behavior should be consistent.
On Mar 7, 2024 at 13:09 +0100, Ivan Petrarka , wrote:
> Note, that in J
I do agree with Ron Liu.
This would definitely need a FLIP as it would impact SQL and extend it with the
equivalent of TimestampAssigners in the Java API.
Is there any existing JIRA here, or is anybody willing to drive a FLIP?
On Feb 26, 2024 at 02:36 +0100, Ron liu , wrote:
> +1,
> But I think t
Hello Irakli and thank you for your question.
I guess that somehow Flink enters the "reactive" mode while the adaptive
scheduler is not configured.
I would go with 2 options to isolate your issue:
• Try with forcing the scheduling mode
(https://nightlies.apache.org/flink/flink-docs-release-1.1
