Weijie Guo created FLINK-35563:
--
Summary: 'Run kubernetes application test' failed on AZP
Key: FLINK-35563
URL: https://issues.apache.org/jira/browse/FLINK-35563
Project: Flink
Issue Type: Bug
Weijie Guo created FLINK-35562:
--
Summary: WindowTableFunctionProcTimeRestoreTest produced no output
for 900 seconds
Key: FLINK-35562
URL: https://issues.apache.org/jira/browse/FLINK-35562
Project: Flink
Thanks Hong!
+1(binding)
- Verified gpg signature
- Verified sha512 hash
- Checked gh release tag
- Checked all artifacts deployed to maven repo
- Ran a simple wordcount job on local standalone cluster
- Compiled from source code with JDK 1.8.0_291.
Best regards,
Weijie
Xiqian YU
+1 (binding)
Best regards,
Weijie
Zhu Zhu 于2024年6月7日周五 16:48写道：
> +1 (binding)
>
> Thanks,
> Zhu
>
> Xintong Song 于2024年6月7日周五 16:08写道：
>
> > +1 (binding)
> >
> > Best,
> >
> > Xintong
> >
> >
> >
> > On Fri, Jun 7, 2024 at 4:03 PM Yuxin Tan wrote:
> >
> > > Hi everyone,
> > >
> > > Thanks
t one issue is used for
> > release tracking
> > - reviewed the web PR
> >
> > Best,
> > Leonard
> >
> > > 2024年5月22日 下午6:10，weijie guo 写道：
> > >
> > > +1(non-binding)
> > >
> > > -Validated checksum hash
Thanks Danny!
+1(binding)
- Verified signatures and hash sums
- Checked the CI build
- Checked the release note
- Reviewed the flink-web PR
- Build from source.
Best regards,
Weijie
Rui Fan <1996fan...@gmail.com> 于2024年6月7日周五 11:08写道：
> Thanks Danny for the hard work!
>
> +1(binding)
>
> -
Thanks Danny!
+1(binding)
- Verified signatures and hashsums
- Build from source
- Checked release tag
- Reviewed the flink-web PR
- Checked the CI build.
Best regards,
Weijie
Rui Fan <1996fan...@gmail.com> 于2024年6月7日周五 11:00写道：
> Thanks Danny for the hard work!
>
> +1(binding)
>
> -
Hi devs,
I'd like to start a discussion about FLIP-462[1]: Support Custom Data
Distribution for Input Stream of Lookup Join.
Lookup Join is an important feature in Flink, It is typically used to
enrich a table with data that is queried from an external system.
If we interact with the external
Congratulations, Rui. Well-deserved!
Best regards,
Weijie
Zakelly Lan 于2024年6月5日周三 18:05写道：
> Congratulations, Rui!
>
> Best,
> Zakelly
>
> On Wed, Jun 5, 2024 at 6:02 PM Piotr Nowojski
> wrote:
>
> > Hi everyone,
> >
> > On behalf of the PMC, I'm very happy to announce another new Apache
Thanks Yuxin for the proposal!
When we first proposed Hybrid Shuffle, I wanted to support pluggable
storage tier in the future. However, limited by the architecture of the
legacy Hybrid Shuffle at that time, this idea has not been realized. The
new architecture abstracts the tier nicely, and now
Weijie Guo created FLINK-35520:
--
Summary: Nightly build can't compile as problems were detected
from NoticeFileChecker
Key: FLINK-35520
URL: https://issues.apache.org/jira/browse/FLINK-35520
Project
Dear devs,
This is the fifth meeting for Flink 1.20 release cycle.
I'd like to share the information synced in the meeting.
- Feature Freeze
It is worth noting that there are only 2 weeks left until the
feature freeze time(June 15, 2024),
and developers need to pay attention to the
Weijie Guo created FLINK-35517:
--
Summary: CI pipeline triggered by pull request seems unstable
Key: FLINK-35517
URL: https://issues.apache.org/jira/browse/FLINK-35517
Project: Flink
Issue Type
Weijie Guo created FLINK-35505:
--
Summary: RegionFailoverITCase.testMultiRegionFailover has never
ever restored state
Key: FLINK-35505
URL: https://issues.apache.org/jira/browse/FLINK-35505
Project
Hi Yang
IIRC, 1.18.2 has not been kicked off yet.
Best regards,
Weijie
Yang LI 于2024年5月30日周四 22:33写道：
> Dear Flink Community,
>
> Anyone know about the release date for 1.18.2?
>
> Thanks very much,
> Yang
>
Hi Jing
> Do we have an umbrella ticket for Flink 1.19 connectors release?
FYI: https://issues.apache.org/jira/browse/FLINK-35131 :)
Best regards,
Weijie
Jing Ge 于2024年5月28日周二 20:29写道：
> Hi,
>
> Thanks Danny for driving it! Do we have an umbrella ticket for Flink 1.19
> connectors release?
Thanks Sergey for driving this release!
+1(non-binding)
1. Verified signatures and hash sums
2. Build from source with 1.8.0_291 succeeded
3. Checked RN.
Best regards,
Weijie
Yuepeng Pan 于2024年5月30日周四 10:08写道：
> +1 (non-binding)
>
> - Built from source code with JDK 1.8 on MaxOS- Run
Weijie Guo created FLINK-35487:
--
Summary: ContinuousFileProcessingCheckpointITCase crashed as
process exit with code 127
Key: FLINK-35487
URL: https://issues.apache.org/jira/browse/FLINK-35487
Project
Weijie Guo created FLINK-35483:
--
Summary: BatchJobRecoveryTest.testRecoverFromJMFailover produced
no output for 900 second
Key: FLINK-35483
URL: https://issues.apache.org/jira/browse/FLINK-35483
Project
+1 for releasing 1.19.1 and Hong as RM.
Thank you for volunteering!
Best regards,
Weijie
Rui Fan <1996fan...@gmail.com> 于2024年5月27日周一 11:45写道：
> +1 for release 1.19.1 and Hong as release manager.
>
> We are really looking forward to this version, thank you.
>
> Best,
> Rui
>
> On Mon, May
Weijie Guo created FLINK-35457:
--
Summary: EventTimeWindowCheckpointingITCase fails on AZP as NPE
Key: FLINK-35457
URL: https://issues.apache.org/jira/browse/FLINK-35457
Project: Flink
Issue
Weijie Guo created FLINK-35456:
--
Summary: WindowAggregateITCase.testEventTimeHopWindow fails on AZP
as NPE
Key: FLINK-35456
URL: https://issues.apache.org/jira/browse/FLINK-35456
Project: Flink
Weijie Guo created FLINK-35443:
--
Summary: ChangelogLocalRecoveryITCase failed fatally with 239 exit
code
Key: FLINK-35443
URL: https://issues.apache.org/jira/browse/FLINK-35443
Project: Flink
+1(binding)
Thanks for driving this!
Best regards,
Weijie
Rui Fan <1996fan...@gmail.com> 于2024年5月24日周五 13:03写道：
> +1(binding)
>
> Best,
> Rui
>
> On Fri, May 24, 2024 at 12:01 PM Yanfei Lei wrote:
>
> > Thanks for driving this!
> >
> > +1 (binding)
> >
> > Best,
> > Yanfei
> >
> > Zakelly
+1(binding)
Best regards,
Weijie
Lincoln Lee 于2024年5月24日周五 12:20写道：
> +1(binding)
>
> Best,
> Lincoln Lee
>
>
> Jane Chan 于2024年5月24日周五 09:52写道：
>
> > Hi all,
> >
> > I'd like to start a vote on FLIP-457[1] after reaching a consensus
> through
> > the discussion thread[2].
> >
> > The vote
Weijie Guo created FLINK-35429:
--
Summary: We don't need introduce getFlinkConfigurationOptions for
SqlGatewayRestEndpointFactory#Context
Key: FLINK-35429
URL: https://issues.apache.org/jira/browse/FLINK-35429
Weijie Guo created FLINK-35428:
--
Summary: WindowJoinITCase#testInnerJoin failed on AZP as NPE
Key: FLINK-35428
URL: https://issues.apache.org/jira/browse/FLINK-35428
Project: Flink
Issue Type
Thanks Ahmed for introducing this FLIP, nice improvement.
+1(binding)
Best regards,
Weijie
Leonard Xu 于2024年5月22日周三 17:25写道：
>
> After discuss with Ahmed, the updated FLIP looks good to me.
>
> +1(binding)
>
>
> Best,
> Leonard
>
> > 2024年5月21日 下午6:12，Hong Liang 写道：
> >
> > +1 (binding)
>
+1(non-binding)
-Validated checksum hash
-Verified signature
-Build from source
Best regards,
Weijie
Hang Ruan 于2024年5月22日周三 10:12写道：
> +1 (non-binding)
>
> - Validated checksum hash
> - Verified signature
> - Verified that no binaries exist in the source archive
> - Build the source with
Thanks Piotr and Zakelly for your advice.
I have also tested this in my local machine, and I can not reproduce
it even if switch to JDK11. This must have something to do with the
benchmark's testing environment.
> I will update FLINK-35040[1] to "Won't fix" and update the Priority from
Blocker
Dear devs,
This is the fourth meeting for Flink 1.20 release cycle.
I'd like to share the information synced in the meeting.
- Feature Freeze
It is worth noting that there are only 4 weeks left until the
feature freeze time(June 15, 2024),
and developers need to pay attention to the
Weijie Guo created FLINK-35416:
--
Summary: Weekly CI for ElasticSearch connector failed to compile
Key: FLINK-35416
URL: https://issues.apache.org/jira/browse/FLINK-35416
Project: Flink
Issue
Weijie Guo created FLINK-35398:
--
Summary: SqlGatewayE2ECase failed to pull image
Key: FLINK-35398
URL: https://issues.apache.org/jira/browse/FLINK-35398
Project: Flink
Issue Type: Bug
+1(binding)
Best regards,
Weijie
Rui Fan <1996fan...@gmail.com> 于2024年5月15日周三 17:50写道：
> +1(binding)
>
> Best,
> Rui
>
> On Wed, May 15, 2024 at 5:01 PM Xuannan Su wrote:
>
> > Hi everyone,
> >
> > Thanks for all the feedback about the FLIP-450: Improve Runtime
> > Configuration for Flink
Thanks Martijn for the effort!
+1(binding)
Best regards,
Weijie
Martijn Visser 于2024年5月14日周二 14:45写道：
> Hi everyone,
>
> With no more discussions being open in the thread [1] I would like to start
> a vote on FLIP-453: Promote Unified Sink API V2 to Public and Deprecate
> SinkFunction [2]
>
Weijie Guo created FLINK-35254:
--
Summary: build_wheels_on_macos failed
Key: FLINK-35254
URL: https://issues.apache.org/jira/browse/FLINK-35254
Project: Flink
Issue Type: Bug
Weijie Guo created FLINK-35246:
--
Summary: SqlClientSSLTest.testGatewayMode failed in AZP
Key: FLINK-35246
URL: https://issues.apache.org/jira/browse/FLINK-35246
Project: Flink
Issue Type: Bug
Weijie Guo created FLINK-35238:
--
Summary: AZP is not working since some ci agent unhealthy
Key: FLINK-35238
URL: https://issues.apache.org/jira/browse/FLINK-35238
Project: Flink
Issue Type: Bug
Thanks Rui for the summary!
Best regards,
Weijie
Rui Fan <1996fan...@gmail.com> 于2024年4月23日周二 17:13写道：
> Dear devs,
>
> Today is the second meeting for
> Flink 1.20 release cycle. I'd like to share
> the information synced in the meeting.
>
> - Features:
> There're 8 weeks until the feature
Weijie Guo created FLINK-35185:
--
Summary: Resuming Externalized Checkpoint(rocks, incremental, no
parallelism change) end-to-end test failed
Key: FLINK-35185
URL: https://issues.apache.org/jira/browse/FLINK-35185
Congratulations, Zakelly!
Best regards,
Weijie
Rui Fan <1996fan...@gmail.com> 于2024年4月15日周一 11:06写道：
> Congratulations!
>
> Best,
> Rui
>
> On Mon, Apr 15, 2024 at 11:01 AM Congxian Qiu
> wrote:
>
> > Congratulations!
> >
> > Best,
> > Congxian
> >
> >
> > Ron liu 于2024年4月15日周一 11:00写道：
> >
Weijie Guo created FLINK-35100:
--
Summary: Quickstarts Java nightly end-to-end test failed on Azure
Key: FLINK-35100
URL: https://issues.apache.org/jira/browse/FLINK-35100
Project: Flink
Issue
Congratulations, Jing!
Best regards,
Weijie
Feng Jin 于2024年4月12日周五 17:24写道：
> Congratulations, Jing
>
> Best,
> Feng Jin
>
> On Fri, Apr 12, 2024 at 4:46 PM Samrat Deb wrote:
>
> > Congratulations, Jing!
> >
> >
> > On Fri, 12 Apr 2024 at 2:15 PM, Jiabao Sun wrote:
> >
> > >
Congratulations, well deserved.
Best regards,
Weijie
Yuepeng Pan 于2024年4月12日周五 16:41写道：
> Congratulations, Lincoln!
>
> Best,Yuepeng Pan
> At 2024-04-12 16:24:01, "Yun Tang" wrote:
> >Congratulations, Lincoln!
> >
> >
> >Best
> >Yun Tang
> >
> >From: Jark Wu
Dear devs,
A few days ago(April 9) we had our first
meeting for Flink 1.20 release cycle. I'd like to share the info
synced in the meeting.
1. Feature freezing and release:
- Feature Freeze
- June 15, 2024, 00:00 CEST(UTC+2)
- Release
- End of July 2024
2. Daily work
Weijie Guo created FLINK-35042:
--
Summary: Streaming File Sink s3 end-to-end test failed as TM lost
Key: FLINK-35042
URL: https://issues.apache.org/jira/browse/FLINK-35042
Project: Flink
Issue
Weijie Guo created FLINK-35041:
--
Summary:
IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
Key: FLINK-35041
URL: https://issues.apache.org/jira/browse/FLINK-35041
Project
Weijie Guo created FLINK-35023:
--
Summary: YARNApplicationITCase failed on Azure
Key: FLINK-35023
URL: https://issues.apache.org/jira/browse/FLINK-35023
Project: Flink
Issue Type: Bug
Thanks all!
Best regards,
Weijie
lorenzo affetti 于2024年4月4日周四
20:04写道：
> The CI is back to normal since this morning.
> Thanks to the collaboration with Robert and Mathias.
>
> For more information, see the issue link in Matthias message.
>
>
>
> On Thu, Apr 4, 2024, 08:23 Matthias Pohl
>
Weijie Guo created FLINK-34998:
--
Summary: Wordcount on Docker test failed on azure
Key: FLINK-34998
URL: https://issues.apache.org/jira/browse/FLINK-34998
Project: Flink
Issue Type: Bug
Weijie Guo created FLINK-34997:
--
Summary: PyFlink YARN per-job on Docker test failed on azure
Key: FLINK-34997
URL: https://issues.apache.org/jira/browse/FLINK-34997
Project: Flink
Issue Type
Weijie Guo created FLINK-34977:
--
Summary: FLIP-433: State Access on DataStream API V2
Key: FLINK-34977
URL: https://issues.apache.org/jira/browse/FLINK-34977
Project: Flink
Issue Type: Sub-task
Congratulations!
Best regards,
Weijie
Hang Ruan 于2024年4月1日周一 09:49写道：
> Congratulations!
>
> Best,
> Hang
>
> Lincoln Lee 于2024年3月31日周日 00:10写道：
>
> > Congratulations!
> >
> > Best,
> > Lincoln Lee
> >
> >
> > Jark Wu 于2024年3月30日周六 22:13写道：
> >
> > > Congratulations!
> > >
> > > Best,
> >
Hi everyone,
The discussion has been going on for a long time and there are currently 4
RM candidates.
According to the voting results, the final release manager of 1.20 are:
Weijie Guo, Rui Fan, Ufuk Celebi and Robert Metzger. We will do the first
release sync on April 9, 2024, at 10am (UTC+2
Hi devs,
I'm happy to announce that FLIP-433: State Access on DataStream API V2
[1] has been accepted with 9 approving votes (4 binding) [2]:
- Xintong Song (binding)
- Hangxiang Yu (binding)
- Rui Fan (binding)
- Gyula Fóra (binding)
- Zakelly Lan (non-binding)
- Jinzhong Li
;> On Fri, 22 Mar 2024 at 07:41, Xintong Song
> > > >> wrote:
> > > >>>
> > > >>>> +1 for the proposed timeline and Weijie & Rui as the release
> > managers.
> > > >>>>
> > > >>>> I think it would b
Thanks Leonard!
> I'd like to help you if you need some help like permissions from PMC
side, please feel free to ping me.
Nice to know. It'll help a lot!
Best regards,
Weijie
Leonard Xu 于2024年3月22日周五 12:09写道：
> +1 for the proposed release managers (Weijie Guo, Rui Fan), both t
Congratulations! Well done.
Best regards,
Weijie
Feng Jin 于2024年3月21日周四 11:40写道：
> Congratulations!
>
>
> Best,
> Feng
>
>
> On Thu, Mar 21, 2024 at 11:37 AM Ron liu wrote:
>
> > Congratulations!
> >
> > Best,
> > Ron
> >
> > Jark Wu 于2024年3月21日周四 10:46写道：
> >
> > > Congratulations and
Weijie Guo created FLINK-34900:
--
Summary: Check compatibility for classes in flink-core-api that
skip japicmp
Key: FLINK-34900
URL: https://issues.apache.org/jira/browse/FLINK-34900
Project: Flink
Weijie Guo created FLINK-34899:
--
Summary: Remove all classes that skip the japicmp check for
flink-core-api
Key: FLINK-34899
URL: https://issues.apache.org/jira/browse/FLINK-34899
Project: Flink
Hi everyone,
Thanks for all the feedback about the FLIP-433: State Access on
DataStream API V2 [1]. The discussion thread is here [2].
The vote will be open for at least 72 hours unless there is an
objection or insufficient votes.
Best regards,
Weijie
[1]
'll also provide some shortcuts to avoid
> having
> > to go through a long build chain each time. Of course, I have updated the
> > the FLIP about this part.
> >
> >
> >
> > Best regards,
> >
> > Weijie
> >
> >
> > weijie guo 于2024年
Hi everyone,
With the release announcement of Flink 1.19, it's a good time to kick off
discussion of the next release 1.20.
- Release managers
I'd like to volunteer as one of the release managers this time. It has been
good practice to have a team of release managers from different
Congratulations!
Thanks release managers and all the contributors involved.
Best regards,
Weijie
Leonard Xu 于2024年3月18日周一 16:45写道：
> Congratulations, thanks release managers and all involved for the great
> work!
>
>
> Best,
> Leonard
>
> > 2024年3月18日 下午4:32，Jingsong Li 写道：
> >
> >
Okay, sorry, I'm not looking at the latest version of the FLIP. You've
answered my question in updated FLIP. :)
Best regards,
Weijie
weijie guo 于2024年3月13日周三 14:56写道：
> Hi Zakelly,
>
> Thanks for the proposal! I like this idea and I can see the performance
> improvemen
> > define a sync and an async version of State with the same name,
> while
> > they
> > >> > cannot allocate two async States with the same name.
> > >> > Another reason for distinguishing API by their method name instead
> of
> > class
> > >
+1 (non-binding)
- Verified signature and checksum
- Verified source distribution does not contains binaries
- Build from source code and submit a word-count job successfully
Best regards,
Weijie
Jane Chan 于2024年3月12日周二 16:38写道：
> +1 (non-binding)
>
> - Verify that the source distributions
ort further configurations such as setTTL in the
future. For ease of use, we'll also provide some shortcuts to avoid having
to go through a long build chain each time. Of course, I have updated the
the FLIP about this part.
Best regards,
Weijie
weijie guo 于2024年3月12日周二 14:00写道：
> Hi Han
Hi Hangxiang,
> So these operators only define all states they may use which could be
explained by the caller, right ?
Yes, you're right.
Best regards,
Weijie
weijie guo 于2024年3月12日周二 13:59写道：
> Hi Max,
>
> > In this thread it looks like the plan is to remove the old stat
StateDeclaration d = States.declare(name).mapState(typeK,
> > > typeV).broadcast();
> > > ```
> > > It can drive users to think about redistribution issues when needed.
> And
> > it
> > > also provides more flexibility to add more combinations such as
>
n also provide interfaces for users
> to declare state ttl?
>
> Best,
> Jinzhong Li
>
>
> On Thu, Mar 7, 2024 at 5:08 PM weijie guo
> wrote:
>
> > Hi Hangxiang,
> >
> > Thanks for your reply!
> >
> > > We have also discussed in FL
estion, I think my answer to Zakelly should be helpful.
Best regards,
Weijie
weijie guo 于2024年3月7日周四 16:58写道：
> Hi Zakelly,
>
> Thanks for your reply!
>
> > My advice would be to conceal RedistributionMode/Strategy from the
> standard user interface, particularly
API level instead of avoiding
it. WDTY?
Best regards,
Weijie
weijie guo 于2024年3月7日周四 16:39写道：
> Hi Gyula,
>
>
> Thanks for your reply!
>
>
> Let me answer these questions:
>
>
> > What is the semantics of the usesStates method? When is it called? Can
> the u
confuse empty value with something
> > > inaccessible.
> > >
> > > 3. The RedistributionMode enum sounds a bit strange to me, as it
> doesn't
> > > actually specify a mode of redistribution. It feels more like a flag.
> Can
> > > we simply have an Opt
Hi devs,
I'd like to start a discussion about FLIP-433: State Access on
DataStream API V2
[1]. This is the third sub-FLIP of DataStream API V2.
After FLIP-410 [2], we can already write a simple stateless job using the
DataStream V2 API. But as we all know, stateful computing is Flink's trump
Weijie Guo created FLINK-34549:
--
Summary: FLIP-410: Config, Context and Processing Timer Service of
DataStream API V2
Key: FLINK-34549
URL: https://issues.apache.org/jira/browse/FLINK-34549
Project
Weijie Guo created FLINK-34548:
--
Summary: FLIP-409: DataStream V2 Building Blocks: DataStream,
Partitioning and ProcessFunction
Key: FLINK-34548
URL: https://issues.apache.org/jira/browse/FLINK-34548
Weijie Guo created FLINK-34547:
--
Summary: Flink DataStream API V2
Key: FLINK-34547
URL: https://issues.apache.org/jira/browse/FLINK-34547
Project: Flink
Issue Type: New Feature
Hi devs,
I'm happy to announce that FLIP-410: Config, Context and Processing
Timer Service of DataStream API V2 [1] has been accepted with 5
approving votes (4 binding) [2]:
- Xintong Song (binding)
- Weijie Guo (binding)
- Rui Fan (binding)
- Xuannan Su (non-binding)
- Guowei Ma (binding
Hi devs,
I'm happy to announce that FLIP-409: DataStream V2 Building Blocks:
DataStream, Partitioning and ProcessFunction [1] has been accepted
with 5 approving votes (4 binding) [2]:
- Xintong Song (binding)
- Weijie Guo (binding)
- Rui Fan (binding)
- Guowei Ma (binding)
- Xuannan Su
Hi devs,
I'm happy to announce that FLIP-408: [Umbrella] Introduce DataStream
API V2 [1] has been accepted with 5 approving votes (4 binding) [2]:
- Xintong Song (binding)
- Weijie Guo (binding)
- Xuannan Su (non-binding)
- Rui Fan (binding)
- Guowei Ma (binding
+1 (binding)
Best regards,
Weijie
Feng Jin 于2024年2月29日周四 09:37写道：
> +1 (non-binding)
>
> Best,
> Feng Jin
>
> On Thu, Feb 29, 2024 at 4:41 AM Márton Balassi
> wrote:
>
> > +1 (binding)
> >
> > Marton
> >
> > On Wed, Feb 28, 2024 at 5:14 PM Gyula Fóra wrote:
> >
> > > +1 (binding)
> > >
> >
+1(binding)
Best regards,
Weijie
Xintong Song 于2024年2月27日周二 09:37写道：
> +1 (binding)
>
> Best,
>
> Xintong
>
>
>
> On Mon, Feb 26, 2024 at 6:10 PM weijie guo
> wrote:
>
> > Hi everyone,
> >
> >
> > Thanks for all the feedback abo
+1(binding)
Best regards,
Weijie
Xintong Song 于2024年2月27日周二 09:38写道：
> +1 (binding)
>
> Best,
>
> Xintong
>
>
>
> On Mon, Feb 26, 2024 at 6:09 PM weijie guo
> wrote:
>
> > Hi everyone,
> >
> >
> > Thanks for all the feedback about th
+1(binding)
Best regards,
Weijie
Xintong Song 于2024年2月27日周二 09:36写道：
> +1 (binding)
>
> Best,
>
> Xintong
>
>
>
> On Mon, Feb 26, 2024 at 6:08 PM weijie guo
> wrote:
>
> > Hi everyone,
> >
> >
> > Thanks for all the feedback about th
Hi everyone,
Thanks for all the feedback about the FLIP-410: Config, Context and
Processing Timer Service of DataStream API V2 [1]. The discussion
thread is here [2].
The vote will be open for at least 72 hours unless there is an
objection or insufficient votes.
[1]
Hi everyone,
Thanks for all the feedback about the FLIP-409: DataStream V2 Building
Blocks: DataStream, Partitioning and ProcessFunction [1]. The
discussion thread is here [2].
The vote will be open for at least 72 hours unless there is an
objection or insufficient votes.
[1]
Hi everyone,
Thanks for all the feedback about the FLIP-408: [Umbrella] Introduce
DataStream API V2 [1]. The discussion thread is here [2].
The vote will be open for at least 72 hours unless there is an
objection or insufficient votes.
[1]
o, will similar
> methods be used to solve them?
>
> Best,
> Guowei
>
>
> On Tue, Feb 20, 2024 at 3:10 PM weijie guo
> wrote:
>
> > Hi All,
> >
> > Thanks for all the feedback.
> >
> > If there are no more comments, I would like to start t
eresting. Looking forward to more detailed discussions in the
> corresponding sub-FLIPs.
>
> +1 for the roadmap.
>
> Best,
>
> Xintong
>
>
>
> On Tue, Jan 30, 2024 at 11:00 AM weijie guo
> wrote:
>
> > Hi Wencong:
> >
> > > The Processin
Hi All,
Thanks for all the feedback.
If there are no more comments, I would like to start the vote thread,
thanks again!
Best regards,
Weijie
Xintong Song 于2024年2月20日周二 14:17写道：
> Thanks for the updates. LGTM.
>
> Best,
>
> Xintong
>
>
>
> On Mon, Feb 19,
Hi All,
Thanks for all the feedback.
If there are no more comments, I would like to start the vote thread,
thanks again!
Best regards,
Weijie
Xintong Song 于2024年2月20日周二 14:17写道：
> LGTM
>
> Best,
>
> Xintong
>
>
>
> On Mon, Feb 19, 2024 at 10:48 AM weijie
Congratulations, Jiabao :)
Best regards,
Weijie
Hang Ruan 于2024年2月19日周一 18:04写道：
> Congratulations, Jiabao!
>
> Best,
> Hang
>
> Qingsheng Ren 于2024年2月19日周一 17:53写道：
>
> > Hi everyone,
> >
> > On behalf of the PMC, I'm happy to announce Jiabao Sun as a new Flink
> > Committer.
> >
> >
ides, we
> need to duplicate them for `NonPartitionedContext`.
> 3. Some of these changes also affect FLIP-410. I noticed that FLIP-410 is
> also updated accordingly. It would be nice to also mention those changes in
> the FLIP-410 discussion thread.
>
> Best,
>
> Xintong
&g
Hi All,
Based on the discussion thread of FLIP-409, I did a synchronized update to
this one. In simple terms, added `TwoInputBroadcastStreamProcessFunction`
related content.
Best regards,
Weijie
weijie guo 于2024年1月31日周三 15:00写道：
> Hi Xintong,
>
> Thanks for the quick reply.
> same way as the keyed input stream. I think this requirement is
> > consistent with that of (KeyedStream, KeyedStream) -> (KeyedStream).
> > Thus, I believe that supporting (KeyedStream, BroadcastStream) ->
> > (KeyedStream) will not introduce complexity for the users. WDYT?
> >
e timer is triggered. In that case, they will need
> additional logic to decide whether the timer should be skipped or not in
> `onProcessingTimer`. Besides, there could also be additional performance
> overhead in frequent calling and skipping the callback.
>
> Best,
>
> Xinton
+1(binding)
Best regards,
Weijie
Rui Fan <1996fan...@gmail.com> 于2024年1月31日周三 12:51写道：
> +1(binding)
>
> Best,
> Rui
>
> On Wed, Jan 31, 2024 at 12:46 PM Xintong Song
> wrote:
>
> > +1
> >
> > Best,
> >
> > Xintong
> >
> >
> >
> > On Wed, Jan 31, 2024 at 11:41 AM Xuannan Su
> wrote:
> >
>
Thanks Dong and Xuannan,
The updated FLIP LGTM.
Best regards,
Weijie
Xuannan Su 于2024年1月30日周二 11:10写道：
> Hi all,
>
> Thanks for the comments and suggestions. If there are no further
> comments, I will open the voting thread tomorrow.
>
> Best regards,
> Xuannan
> On Fri, Jan 26, 2024 at
e timer.
Best regards,
Weijie
weijie guo 于2024年1月30日周二 14:35写道：
> Hi Xuannan,
>
> > 1. +1 to only use XXXParititionStream if users only need to use the
> configurable PartitionStream. If there are use cases for both,
> perhaps we could use `ProcessC
1 - 100 of 304 matches
Mail list logo
