Jacky Lau created FLINK-37009:
-
Summary: Migrate PruneAggregateCallRule
Key: FLINK-37009
URL: https://issues.apache.org/jira/browse/FLINK-37009
Project: Flink
Issue Type: Sub-task
Compo
Thank you Matthias and all for the feedback and suggestions.
Please let me make a brief summary based on the historical comments:
- It's agreeded to optimize/fix this issue in the 1.x TLS versions.
- The primary goal of this optimization/fix is to minimize the number of
TaskManagers used in appli
Thank you Matthias and all for the feedback and suggestions.
Please let me make a brief summary based on the historical comments:
- It's agreeded to optimize/fix this issue in the 1.x TLS versions.
- The primary goal of this optimization/fix is to minimize the number of
TaskManagers used in appli
Hi, Anil
Maybe the watermark alignment mechanism on DataStream V1 can solve your
problem, it can align the watermark of SourceSplit.
please refer to the documentation [1][2].
And we don't provide this feature on this FLIP, this feature will be in our
future planning.
[1]
https://cwiki.apache.org/
Hi, Xu
Thanks for your work, I noticed that in this FLIP, event-time watermark is
created and sent through a separate WatermarkGenerator. I would like to
know if there is support for Source to send event-time watermark?
Best,
Junrui
Xu Huang 于2025年1月6日周一 10:31写道:
> Hi, Anil
>
> Maybe the water
Hi, Junrui
Thanks for your question, Source is able to send event-time watermark.
It can be sent via SourceReaderContext as mentioned in FLIP-467. Example is
as follows: >
sourceReaderContext.emitWatermark(EventTimeExtension.EVENT_TIME_WATERMARK_DECLARATION.newWatermark(eventTime))
We will add it
Ryan van Huuksloot created FLINK-37008:
--
Summary: Flink UI should show the type of checkpoint (full vs
incremental)
Key: FLINK-37008
URL: https://issues.apache.org/jira/browse/FLINK-37008
Project
Zakelly Lan created FLINK-37010:
---
Summary: Unify KeyedProcessFunction and the async one
Key: FLINK-37010
URL: https://issues.apache.org/jira/browse/FLINK-37010
Project: Flink
Issue Type: Sub-ta
also myself
+1 (binding)
On Thu, Jan 2, 2025 at 4:08 AM Xuyang wrote:
> +1 (non-binding)
>
>
> --
>
> Best!
> Xuyang
>
>
>
>
>
> 在 2024-12-31 16:48:15,"Dawid Wysakowicz" 写道:
> >+1(binding)
> >Best,
> >Dawid
> >
> >On Tue, 24 Dec 2024 at 08:27, Feng Jin wrote:
> >
> >> +1 (non-binding)
Hi everyone,
I'm delighted to announce that FLIP-494 [1] has been accepted.
There were 6 +1 votes, 3 of which are binding:
- Ron Liu (binding)
- Yuepeng Pan (non-binding)
- Feng Jin (non-binding)
- Dawid Wysakowicz (binding)
- Xuyang (non-binding)
- Sergey Nuyanzin (binding)
There were no -1 vo
The voting time for FLIP-494: Add missing createTable/createView methods to
TableEnvironment [1] has passed.
I'm closing the vote now.
[1]
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=334760466
On Sun, Jan 5, 2025 at 7:21 PM Sergey Nuyanzin wrote:
> also myself
> +1 (bin
Hi everyone and sorry for the late reply. I was mostly off in November and
forgot about that topic in December last year.
Thanks for summarizing and bringing up user feedback. I see the problem and
agree with your view that it's a topic that we might want to address in the
1.x LTS version. I see h
Weijie Guo created FLINK-36934:
--
Summary: Enrich numSubpartitions to
TierMasterAgent#addPartitionAndGetShuffleDescriptor
Key: FLINK-36934
URL: https://issues.apache.org/jira/browse/FLINK-36934
Project: F
Sergey Nuyanzin created FLINK-37007:
---
Summary: FLIP-494: Add missing createTable/createView methods to
TableEnvironment
Key: FLINK-37007
URL: https://issues.apache.org/jira/browse/FLINK-37007
Projec
14 matches
Mail list logo