Hi all,
I'm glad to announce that the FLIP-501 [1] has been accepted. The voting
thread is here[2].
The proposal received 3 approving votes, all of which are binding:
- Weijie Guo (binding)
- Junrui Lee (binding)
- Zakelly Lan (binding)
And there is no disapproving one.
Thanks to all participan
Hi all,
I'm glad to announce that the FLIP-500 [1] has been accepted. The voting
thread is here[2].
The proposal received 4 approving votes, 3 of which are binding:
- Weijie Guo (binding)
- Junrui Lee (binding)
- Xintong Song (binding)
- Yuepeng Pan
And there is no disapproving one.
Thanks to a
Weijie Guo created FLINK-37148:
--
Summary: Add documentation for datastream v2 api
Key: FLINK-37148
URL: https://issues.apache.org/jira/browse/FLINK-37148
Project: Flink
Issue Type: New Feature
lixu created FLINK-37147:
Summary: The where condition run time advance caused a program
error
Key: FLINK-37147
URL: https://issues.apache.org/jira/browse/FLINK-37147
Project: Flink
Issue Type: Bug
Naijie Liu created FLINK-37146:
--
Summary: Prometheus Push Gateway not work on 1.18.1
Key: FLINK-37146
URL: https://issues.apache.org/jira/browse/FLINK-37146
Project: Flink
Issue Type: Bug
+1 (non-binding)
Best,
Yuepeng Pan
在 2025-01-16 09:54:02，"Xintong Song" 写道：
>+1 (binding)
>
>Best,
>
>Xintong
>
>
>
>On Tue, Jan 14, 2025 at 10:56 AM Junrui Lee wrote:
>
>> +1(binding)
>>
>> Best,
>> Junrui
>>
>> weijie guo 于2025年1月14日周二 10:32写道：
>>
>> > +1(binding)
>> >
>> > Best regards,
>>
Weijie Guo created FLINK-37145:
--
Summary:
testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot failed on
AZP
Key: FLINK-37145
URL: https://issues.apache.org/jira/browse/FLINK-37145
Proje
Thanks for reviewing, Xuyang!
Xingcan (@xingc...@gmail.com) – do you have any concerns?
If no further objections arise from anyone, I’ll proceed to mark FLIP as
ready for voting.
Best regards,
Weiqing
On Tue, Jan 14, 2025 at 9:06 PM Xuyang wrote:
> LGTM overall. Thanks for updating. I have no
+1 (binding)
Best,
Xintong
On Tue, Jan 14, 2025 at 10:56 AM Junrui Lee wrote:
> +1(binding)
>
> Best,
> Junrui
>
> weijie guo 于2025年1月14日周二 10:32写道：
>
> > +1(binding)
> >
> > Best regards,
> >
> > Weijie
> >
> >
> > Xu Huang 于2025年1月13日周一 14:55写道：
> >
> > > Hi, all.
> > >
> > > I'd like to
Yanquan Lv created FLINK-37143:
--
Summary: Update version of flink-connector-kafka to 4.0-SNAPSHOT
Key: FLINK-37143
URL: https://issues.apache.org/jira/browse/FLINK-37143
Project: Flink
Issue Typ
Hi Tom and David,
The Stale PR message isn't a big problem, I think we could ignore it for
the old PRs.
I'm not sure if they will be closed after 90 days if some PR is not labeled
as 'stale'?
If yes, I think it's not a big problem, we could ignore it as well.
If not, we need to address it.
WDYT?
Yanquan Lv created FLINK-37144:
--
Summary: Update flink-connector-kafka version to 3.4-SNAPSHOT
Key: FLINK-37144
URL: https://issues.apache.org/jira/browse/FLINK-37144
Project: Flink
Issue Type:
Yanquan Lv created FLINK-37142:
--
Summary: Update version of flink-connector-kafka to 4.0-SNAPSHOT
Key: FLINK-37142
URL: https://issues.apache.org/jira/browse/FLINK-37142
Project: Flink
Issue Typ
Hector Miuler Malpica Gallegos created FLINK-37141:
--
Summary: The version of the Flink Operator in operatorhub.io is
old 1.6.0
Key: FLINK-37141
URL: https://issues.apache.org/jira/browse/FLINK-371
Hi Alan,
Thanks for working on this FLIP!
Overall the document looks very good, but I have a few question / comments:
* Why do we need the `canBundle()` function? We can use the interface
itself as a marker. A function that can't bundle, shouldn't implement the
interface.
* the interface could
Hi all,
The FLIP looks good to me and I think as well that we should continue with
it.
The hints proposed in FLIP-313 can be added later if needed.
Thanks, Fabian
On Tue, Jan 14, 2025 at 1:50 PM Timo Walther wrote:
> Hi Alan,
>
> thanks for giving us some context. It looks like FLIP-313 has n
Thanks for the update Dawid.
From my point of view, the FLIP is ready for voting. Unless somebody
else has any objections?
Cheers,
Timo
On 15.01.25 10:20, Dawid Wysakowicz wrote:
Sure, I updated the FLIP
On Mon, 13 Jan 2025 at 15:20, Timo Walther wrote:
Hi Dawid,
thanks for proposing
I think clearing the cache and re-running should work.
However, there was an issue with the formatting of the Stale PR message (that
got imported from the Apache Kafka version it is based on). I have fixed that
in this PR [1], so if that can be merged first before clearing the cache that
would
Hi Rui,
Looks good. I ran:
https://github.com/apache/flink/pulls?q=is%3Apr+is%3Aopen+This+PR+is+being+marked+as+stale+since+it+has+not+had+any+activity+in+the+last+180+days.
And there are 610 open PRs. I am wondering how we get the stale label onto
those PRs. Some thoughts
1. We write batch s
Hi all,
With commit 997b48340d2aac1de48c0788b4204d660e34cedd the master branch has
been switched to use Java 17 by default. Support for Java 8 has been
dropped, and there is a separate profile to run against Java 11 (this is
still being run during the cron builds).
The README on how to build loca
Yanfei Lei created FLINK-37140:
--
Summary: Create InternalTimerServiceAsyncImpl when restore async
operator
Key: FLINK-37140
URL: https://issues.apache.org/jira/browse/FLINK-37140
Project: Flink
Hi devs,
We are having the feature freeze for Flink 2.0 on Jan 20.
After the freeze, only bugfix code changes are allowed to be merged for the
2.0 release. Features and improvements are not allowed.
If there's any feature and improvement code changes that you'd like to see
in Flink 2.0 that may
Lei Yang created FLINK-37139:
Summary: Improve AdaptiveSkewedJoinOptimizationStrategy to make it
effective in more scenarios
Key: FLINK-37139
URL: https://issues.apache.org/jira/browse/FLINK-37139
Project
Sure, I updated the FLIP
On Mon, 13 Jan 2025 at 15:20, Timo Walther wrote:
> Hi Dawid,
>
> thanks for proposing this FLIP. It nicely completes the serialization
> effort started with FLIP-393. I know naming is difficult, but could we
> shorten and simplify the signatures further?
>
> My suggest
Hi devs,
Here's a summary of today's release sync.
- The *feature freeze* date of Flink 2.0 is *Jan 20*.
- We'll cut the release branch and create RC0 (for testing purpose,
will not be voted on) immediately after the feature freeze
- Important dates for developers
- Please
Weijie Guo created FLINK-37138:
--
Summary: testDeployScriptViaSqlClient failed on AZP
Key: FLINK-37138
URL: https://issues.apache.org/jira/browse/FLINK-37138
Project: Flink
Issue Type: Bug
Weijie Guo created FLINK-37137:
--
Summary: testGenerateStreamGraphJson failed on AZP
Key: FLINK-37137
URL: https://issues.apache.org/jira/browse/FLINK-37137
Project: Flink
Issue Type: Bug
xuhuang created FLINK-37136:
---
Summary: FLIP-501: Support Window Extension in DataStream V2 API
Key: FLINK-37136
URL: https://issues.apache.org/jira/browse/FLINK-37136
Project: Flink
Issue Type: New
xuhuang created FLINK-37135:
---
Summary: FLIP-500: Support Join Extension in DataStream V2 API
Key: FLINK-37135
URL: https://issues.apache.org/jira/browse/FLINK-37135
Project: Flink
Issue Type: New F
Thanks for working on this awesome new feature!
-Max
On Mon, Jan 13, 2025 at 1:01 PM Gabor Somogyi wrote:
>
> Hi All,
>
> I'm glad to announce that the FLIP-496: SQL connector for keyed state
> data[1] has been accepted. The voting thread is here[2].
>
> The proposal received 4 approving votes,
Hey Yuepeng,
I think that would work.
Thanks,
Max
On Sun, Jan 12, 2025 at 3:42 PM Yuepeng Pan wrote:
>
> Hi, Maximilian, Thank you very much for your reply and suggestions.
>
> That makes sense to me.
>
>
>
>
> > Do you think we could condition the DefaultSlotAssigner based
>
> > on whether the
Feng Jin created FLINK-37134:
Summary: Cross-team verification for FLIP-492
Key: FLINK-37134
URL: https://issues.apache.org/jira/browse/FLINK-37134
Project: Flink
Issue Type: Sub-task
32 matches
Mail list logo
