+1(binding), thanks for driving this improvement.
Best,
Rui Fan
On Sat, Jun 24, 2023 at 4:55 AM Jing Ge wrote:
> +1(binding)
>
> Best Regards,
> Jing
>
> On Fri, Jun 23, 2023 at 5:50 PM Lijie Wang
> wrote:
>
> > Hi all,
> >
> > Thanks for all the feedback about the FLIP-324: Introduce Runtime
+1(binding)
Best Regards,
Jing
On Fri, Jun 23, 2023 at 5:50 PM Lijie Wang wrote:
> Hi all,
>
> Thanks for all the feedback about the FLIP-324: Introduce Runtime Filter
> for Flink Batch Jobs[1]. This FLIP was discussed in [2].
>
> I'd like to start a vote for it. The vote will be open for at
Hi all,
I have been looking at the Flink REST API implementation, and had some question
on potential improvements. Looking to gather some thoughts:
1. Only use what is necessary. The GET /checkpoints API seems to be using the
cached version of the entire Execution graph (stale data), when it
Matthias Pohl created FLINK-32422:
-
Summary: EmbeddedLeaderService doesn't handle the leader events
properly in edge cases
Key: FLINK-32422
URL: https://issues.apache.org/jira/browse/FLINK-32422
Matthias Pohl created FLINK-32421:
-
Summary:
EmbeddedLeaderServiceTest.testConcurrentRevokeLeadershipAndShutdown is not
properly implemented
Key: FLINK-32421
URL:
Hi all,
Thanks for all the feedback about the FLIP-324: Introduce Runtime Filter
for Flink Batch Jobs[1]. This FLIP was discussed in [2].
I'd like to start a vote for it. The vote will be open for at least 72
hours (until June 29th 12:00 GMT) unless there is an objection or
insufficient votes.
Rui Fan created FLINK-32420:
---
Summary: Watermark aggregation performance is poor when watermark
alignment is enabled and parallelism is high
Key: FLINK-32420
URL: https://issues.apache.org/jira/browse/FLINK-32420
Thanks Jing. I can only offer my perspective on this, others may view it
differently.
If FileSink is subject to data loss in the "stop-on-savepoint then restart"
scenario, that makes it unusable for me, and presumably for anyone who uses
it in a long-running streaming application and who cannot
Matthias Pohl created FLINK-32419:
-
Summary: Remove unused/obsolete classes
Key: FLINK-32419
URL: https://issues.apache.org/jira/browse/FLINK-32419
Project: Flink
Issue Type: Sub-task
