+1 (non-binding)
- Checked sign
- Checked the hash
- Checked tag
- Build from source
Best,
Yuxin
weijie guo 于2023年5月29日周一 14:14写道：
> +1 (non-binding)
>
> - checked sign and checksum
> - checked tag in github repository
> - compiled from source
> - checked the web PR
>
> BTW, please remember
Yuxin Tan created FLINK-32194:
-
Summary: Elasticsearch connector should remove the dependency on
flink-shaded
Key: FLINK-32194
URL: https://issues.apache.org/jira/browse/FLINK-32194
Project: Flink
Yuxin Tan created FLINK-32193:
-
Summary: AWS connector removes the dependency on flink-shaded
Key: FLINK-32193
URL: https://issues.apache.org/jira/browse/FLINK-32193
Project: Flink
Issue Type
+1 (non-binding)
- verified the signatures
- verified the checksums
- built from source
- start a standalone cluster, run a simple batch and a streaming job
successfully
- review release announcement PR
Best,
Yuxin
Xintong Song 于2023年5月22日周一 18:24写道：
> +1 (binding)
>
> - verified signatures
+1 (non-binding)
- Verified signature
- Verified hashes
- Build form source with mac
- Verify that the source archives do not contain any binaries
- Run streaming and batch job in sql-client successfully.
Thanks weijie for driving this release candidate.
Best,
Yuxin
weijie guo 于2023年5月19日周五
Yuxin Tan created FLINK-32101:
-
Summary: FlinkKafkaInternalProducerITCase.testInitTransactionId
test failed
Key: FLINK-32101
URL: https://issues.apache.org/jira/browse/FLINK-32101
Project: Flink
Yuxin Tan created FLINK-32060:
-
Summary: Migrate subclasses of BatchAbstractTestBase in table and
other modules to JUnit5
Key: FLINK-32060
URL: https://issues.apache.org/jira/browse/FLINK-32060
Project
Yuxin Tan created FLINK-32059:
-
Summary: Migrate subclasses of BatchAbstractTestBase in
batch.sql.agg and batch.sql.join to JUnit5
Key: FLINK-32059
URL: https://issues.apache.org/jira/browse/FLINK-32059
Yuxin Tan created FLINK-32058:
-
Summary: Migrate subclasses of BatchAbstractTestBase in
runtime.batch.sql to JUnit5
Key: FLINK-32058
URL: https://issues.apache.org/jira/browse/FLINK-32058
Project: Flink
Yuxin Tan created FLINK-32055:
-
Summary: Migrate all subclasses of BatchAbstractTestBase to JUnit5
Key: FLINK-32055
URL: https://issues.apache.org/jira/browse/FLINK-32055
Project: Flink
Issue
Congratulations, Leonard!
Best,
Yuxin
Panagiotis Garefalakis 于2023年4月22日周六 08:08写道：
> Congrats Leonard!
>
> On Fri, Apr 21, 2023 at 11:19 AM Ahmed Hamdy wrote:
>
> > Congratulations Leonard.
> > Best Regards
> > Ahmed
> >
> > On Fri, 21 Apr 2023 at 17:23, Samrat Deb wrote:
> >
> > >
Congratulations, Qingsheng!
Best,
Yuxin
Ahmed Hamdy 于2023年4月22日周六 02:20写道：
> Congratulations Qingsheng.
> Best regards
> Ahmed
>
> On Fri, 21 Apr 2023 at 17:22, Samrat Deb wrote:
>
> > congratulations !
> >
> > On Fri, 21 Apr 2023 at 9:45 PM, David Morávek wrote:
> >
> > > Congratulations,
Yuxin Tan created FLINK-31878:
-
Summary: Fix the wrong name of PauseOrResumeSplitsTask#toString in
connector fetcher
Key: FLINK-31878
URL: https://issues.apache.org/jira/browse/FLINK-31878
Project
Yuxin Tan created FLINK-31720:
-
Summary: Pulsar connector v3.0 branch's docs are empty
Key: FLINK-31720
URL: https://issues.apache.org/jira/browse/FLINK-31720
Project: Flink
Issue Type: Bug
Yuxin Tan created FLINK-31688:
-
Summary: Broken links in docs for Azure Table Storage
Key: FLINK-31688
URL: https://issues.apache.org/jira/browse/FLINK-31688
Project: Flink
Issue Type: Bug
Yuxin Tan created FLINK-31671:
-
Summary: [Connectors/HBase] Update flink to 1.17.0
Key: FLINK-31671
URL: https://issues.apache.org/jira/browse/FLINK-31671
Project: Flink
Issue Type: Improvement
Yuxin Tan created FLINK-31647:
-
Summary: Introduce remote storage tier reader
Key: FLINK-31647
URL: https://issues.apache.org/jira/browse/FLINK-31647
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31646:
-
Summary: Introduce remote storage tier
Key: FLINK-31646
URL: https://issues.apache.org/jira/browse/FLINK-31646
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31644:
-
Summary: Introduce disk tier
Key: FLINK-31644
URL: https://issues.apache.org/jira/browse/FLINK-31644
Project: Flink
Issue Type: Sub-task
Components
Yuxin Tan created FLINK-31645:
-
Summary: Introduce disk tier reader
Key: FLINK-31645
URL: https://issues.apache.org/jira/browse/FLINK-31645
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31643:
-
Summary: Introduce a temporary switch to enable the new shuffle
implementation
Key: FLINK-31643
URL: https://issues.apache.org/jira/browse/FLINK-31643
Project: Flink
Yuxin Tan created FLINK-31641:
-
Summary: Introduce memory tier
Key: FLINK-31641
URL: https://issues.apache.org/jira/browse/FLINK-31641
Project: Flink
Issue Type: Sub-task
Components
Yuxin Tan created FLINK-31642:
-
Summary: Introduce memory tier reader
Key: FLINK-31642
URL: https://issues.apache.org/jira/browse/FLINK-31642
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31640:
-
Summary: Introduce segment index tracker
Key: FLINK-31640
URL: https://issues.apache.org/jira/browse/FLINK-31640
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31639:
-
Summary: Introduce tiered store memory manager
Key: FLINK-31639
URL: https://issues.apache.org/jira/browse/FLINK-31639
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31638:
-
Summary: Downstream supports reading buffers from tiered store
Key: FLINK-31638
URL: https://issues.apache.org/jira/browse/FLINK-31638
Project: Flink
Issue Type
Yuxin Tan created FLINK-31637:
-
Summary: Introduce buffer accumulator tier
Key: FLINK-31637
URL: https://issues.apache.org/jira/browse/FLINK-31637
Project: Flink
Issue Type: Sub-task
Yuxin Tan created FLINK-31636:
-
Summary: Upstream supports reading buffers from tiered store
Key: FLINK-31636
URL: https://issues.apache.org/jira/browse/FLINK-31636
Project: Flink
Issue Type
Yuxin Tan created FLINK-31635:
-
Summary: Support writing records to the new tiered store
architecture
Key: FLINK-31635
URL: https://issues.apache.org/jira/browse/FLINK-31635
Project: Flink
Yuxin Tan created FLINK-31634:
-
Summary: FLIP-301: Hybrid Shuffle supports Remote Storage
Key: FLINK-31634
URL: https://issues.apache.org/jira/browse/FLINK-31634
Project: Flink
Issue Type: New
Congratulations！
Best,
Yuxin
Guanghui Zhang 于2023年3月28日周二 11:06写道：
> Congratulations！
>
> Best,
> Zhang Guanghui
>
> Hang Ruan 于2023年3月28日周二 10:29写道：
>
> > Congratulations!
> >
> > Best,
> > Hang
> >
> > yu zelin 于2023年3月28日周二 10:27写道：
> >
> >> Congratulations!
> >>
> >> Best,
> >> Yu Zelin
Hi all,
I am happy to announce that FLIP-301: Hybrid Shuffle supports Remote
Storage[1] has been accepted. The FLIP was voted in this thread[2].
There are 4 binding votes and 3 non-binding votes:
- Wencong Liu (non-binding)
- Weihua Hu (non-binding)
- Junrui Lee (non-binding)
- weijie guo
4:24写道：
> > > >
> > > > > +1 (non-binding)
> > > > >
> > > > > Best,
> > > > > Weihua
> > > > >
> > > > >
> > > > > On Mon, Mar 20, 2023 at 12:39 PM Wencong Liu >
> > > > wrote:
> > > > >
> > >
Hi, everyone,
Thanks for all your feedback for FLIP-301: Hybrid Shuffle
supports Remote Storage[1] on the discussion thread[2].
I'd like to start a vote for it. The vote will be open for at
least 72 hours (03/23, 13:00 UTC+8) unless there is an
objection or not enough votes.
[1]
Hi all,
Thanks for all the feedback and suggestions so far.
The discussion has been going on for some time. If there are no
further comments, we will start voting today.
Best,
Yuxin
Yuxin Tan 于2023年3月17日周五 12:52写道：
> Hi,
> Thanks for joining the discussion and giving the ideas.
&g
Hi,
Thanks for joining the discussion and giving the ideas.
@ron
> can the Hybrid Shuffle replace the RSS in the future?
The hybrid shuffle and RSS offer distinct solutions to address
the shuffle operation challenge. To optimize performance, we
store shuffle data in different tiers of memory and
plicitly in the original FLIP's goals or
> design principles.
>
>
> Best
> Yun Tang
> ____
> From: Yuxin Tan
> Sent: Wednesday, March 15, 2023 12:41
> To: dev@flink.apache.org
> Subject: Re: [DISCUSS] FLIP-301: Hybrid Shuffle suppo
ld
> switch to kick shuffle data to remote storage once no space left exception
> is met.
>
>
> [1]
> https://www.alibabacloud.com/help/en/realtime-compute-for-apache-flink/latest/geministatebackend-configurations#section-u0y-on0-owo
>
>
> Best
> Yun Tang
>
> ___
assumption that tier changing would not be very frequent.
> >
> > Thanks,
> > Zhu
> >
> > Weihua Hu 于2023年3月10日周五 11:52写道：
> > >
> > > Thanks Yuxin for your explanation.
> > >
> > > That sounds reasonable. Looking
退订请发任意内容到 dev-unsubscr...@flink.apache.org [1]
[1] https://flink.apache.org/community/
Best,
Yuxin
MuChen <9329...@qq.com.invalid> 于2023年3月13日周一 08:48写道：
> 退订
>
>
>
>
> MuChen
> 9329...@qq.com
>
>
>
>
Congratulations, Yuxia!
Best,
Yuxin
Jark Wu 于2023年3月13日周一 10:26写道：
> Hi, everyone
>
> On behalf of the PMC, I'm very happy to announce Yuxia Luo as a new Flink
> Committer.
>
> Yuxia has been continuously contributing to the Flink project for almost
> two
> years, authored and reviewed
Yuxin Tan created FLINK-31396:
-
Summary: Occasional inaccurate timeout time calculation with
System.nanotime in batch read buffer pool
Key: FLINK-31396
URL: https://issues.apache.org/jira/browse/FLINK-31396
Thanks, Weihua!
+1 (non-binding)
Best,
Yuxin
weijie guo 于2023年3月10日周五 11:29写道：
> +1 (binding)
>
> Best regards,
>
> Weijie
>
>
> Shammon FY 于2023年3月10日周五 11:02写道：
>
> > Thanks weihua, +1 (non-binding)
> >
> > Best,
> > Shammon
> >
> > On Fri, Mar 10, 2023 at 10:32 AM Xintong Song
> > wrote:
d of
> storage tier.
> Shall we move the local data to remote storage if the producer is finished
> for a long time?
> So we can release the idle task manager with no shuffle data on it. This
> may help to reduce
> the resource usage when producer parallelism is larger than consu
his FLIP. Are these three values fixed at present? If they are fixed, I
> suggest that FLIP
> could provide clearer explanations. Moreover, although a dynamic segment
> size
> mechanism is not necessary at the moment, can we provide configuration
> options for users
> to manually adju
utilization
> rate of Memory Storage Tier, but it may brings extra cost to Disk Storage
> Tier or Remote Storage Tier. Deciding the size of Segment dynamicly will be
> helpful.
>
> Best,
>
>
> Wencong Liu
>
>
>
>
>
>
>
>
>
>
>
>
>
>
&
Hi everyone,
I would like to start a discussion on FLIP-301: Hybrid Shuffle supports
Remote Storage[1].
In the cloud-native environment, it is difficult to determine the
appropriate
disk space for Batch shuffle, which will affect job stability.
This FLIP is to support Remote Storage for Hybrid
Yuxin Tan created FLINK-31314:
-
Summary: Hybrid
Key: FLINK-31314
URL: https://issues.apache.org/jira/browse/FLINK-31314
Project: Flink
Issue Type: Improvement
Reporter: Yuxin Tan
Congratulations, Dong!
Best,
Yuxin
ConradJam 于2023年2月17日周五 09:59写道：
> Congratulations Dong
>
> Dong Lin 于2023年2月16日周四 21:32写道：
>
> > Thank you all!
> >
> > I am looking forward to making more contributions to Apache Flink!
> >
> > On Thu, Feb 16, 2023 at 8:34 PM Jark Wu wrote:
> >
> > >
Congratulations, Jing Ge!
Best,
Yuxin
Shengkai Fang 于2023年2月15日周三 10:52写道：
> Congratulations!
>
> Best,
> Shengkai
>
> Yanfei Lei 于2023年2月15日周三 10:08写道：
>
> > Congratulations, Jing Ge !
> >
> > Best regards,
> > Yanfei
> >
> > yuxia 于2023年2月15日周三 09:34写道：
> > >
> > > Congratulations, Jing
Congratulations, Weijie!
Best,
Yuxin
Yanfei Lei 于2023年2月13日周一 12:16写道：
> Congratulations, Weijie!
>
> Best regards,
> Yanfei
>
> Junrui Lee 于2023年2月13日周一 12:12写道：
> >
> > Congratulations, Weijie!
> >
> > Best,
> > Junrui
>
Yuxin Tan created FLINK-30712:
-
Summary: Update network memory configuration docs
Key: FLINK-30712
URL: https://issues.apache.org/jira/browse/FLINK-30712
Project: Flink
Issue Type: Improvement
Congratulations, Lincoln!
Best,
Yuxin
Qingsheng Ren 于2023年1月10日周二 14:11写道：
> Congratulations, Lincoln!
>
> Best,
> Qingsheng
>
> On Tue, Jan 10, 2023 at 2:06 PM yuxia wrote:
>
> > Congratulations, Lincoln!
> >
> > Best regards,
> > Yuxia
> >
> > - 原始邮件 -
> > 发件人: "Shuiqiang Chen"
>
;
> 17610775726 <17610775...@163.com> 于2023年1月4日周三 13:03写道：
>
> >
> >
> > +1 (no binding)
> >
> >
> > Best
> > JasonLee
> >
> >
> > Replied Message
> > | From | Yuxin Tan |
> > | Date | 01/
Hi all,
FLIP-266: Simplify network memory configurations for TaskManager[1]
has been accepted. The FLIP was voted in this thread[2].
There are 3 bindings, and 1 non-bindings as follows:
Xintong Song (binding)
Zhu Zhu (binding)
JasonLee (no-binding)
Lijie Wang (binding)
There are no
Hi all,
Thanks for all the feedback so far.
Based on the discussion[1], we have come to a consensus,
so I would like to start a vote on FLIP-266: Simplify network
memory configurations for TaskManager[2].
The vote will last for at least 72 hours (Jan 6th at 11:00 GMT)
unless there is an
Hi all,
Thanks for all the feedback so far.
The discussion has been going on for some time. If there are no
more new comments, we will start a vote today.
Best,
Yuxin
Yuxin Tan 于2022年12月29日周四 17:37写道：
> Hi, everyone
>
> Thanks for the reply and the discussion.
>
&g
method.
- When the memory used reaches the threshold, the number of exclusive
buffers is gradually reduced in a fine-grained manner, rather than directly
reducing the number of exclusive buffers to 0.
Best,
Yuxin
Yuxin Tan 于2022年12月29日周四 14:48写道：
> Hi, Roman
>
> Sorry about that I m
a reasonable value, but I have a small
> > problem. network memory is not only related to the parallelism of the
> task,
> > but also to the complexity of the task DAG. The more complex a DAG is,
> > shuffle write and shuffle read require larger buffers. How can we
> dete
value, but I have a small
> > problem. network memory is not only related to the parallelism of the
> task,
> > but also to the complexity of the task DAG. The more complex a DAG is,
> > shuffle write and shuffle read require larger buffers. How can we
> determine
> > how ma
uffle write and shuffle read require larger buffers. How can we determine
> how many RS and IG a DAG has?
>
>
>
> Best
> JasonLee
>
>
> Replied Message
> | From | Yuxin Tan |
> | Date | 12/28/2022 18:29 |
> | To | |
> | Subject | Re: [DISCUSS] F
f shuffles will likely result in using
> exclusive buffers
> for point-wise connections and floating buffers for all-to-all ones. I'm
> not sure if that's always optimal. It would be great to have experimental
> results for jobs with different exchange types, WDYT?
>
> [1]
&
gt; to control maximum read network buffer usage.
> Do we really need to change the default value of
> 'taskmanager.memory.network.max'?
>
> Best,
> Weihua
>
>
> On Mon, Dec 26, 2022 at 6:26 PM Yuxin Tan wrote:
>
> > Hi, all
> > Thanks for the reply and feedback for everyone!
>
t might be helpful to add a dedicated public interface
> section
> > > to describe the config key and config semantics, as suggested in the
> FLIP
> > > template here
> > > <
> > >
> https://cwiki.apache.org/confluence/display/FLINK/Flink+Imp
Yuxin Tan created FLINK-30473:
-
Summary: Optimize the InputGate network memory management for
TaskManager
Key: FLINK-30473
URL: https://issues.apache.org/jira/browse/FLINK-30473
Project: Flink
Yuxin Tan created FLINK-30472:
-
Summary: Modify the default value of the max network memory config
option
Key: FLINK-30472
URL: https://issues.apache.org/jira/browse/FLINK-30472
Project: Flink
Yuxin Tan created FLINK-30471:
-
Summary: Optimize the enriching network memory process in
SsgNetworkMemoryCalculationUtils
Key: FLINK-30471
URL: https://issues.apache.org/jira/browse/FLINK-30471
Project
Yuxin Tan created FLINK-30469:
-
Summary: FLIP-266: Simplify network memory configurations for
TaskManager
Key: FLINK-30469
URL: https://issues.apache.org/jira/browse/FLINK-30469
Project: Flink
Hi, devs,
I'd like to start a discussion about FLIP-266: Simplify network memory
configurations for TaskManager[1].
When using Flink, users may encounter the following issues that affect
usability.
1. The job may fail with an "Insufficient number of network buffers"
exception.
2. Flink network
Hi, Stan
You could get more contribution details here. [1]
Thanks and looking forward to your contribution!
[1] https://flink.apache.org/contributing/how-to-contribute.html
Best,
Yuxin
Martijn Visser 于2022年12月5日周一 14:21写道：
> Hi,
>
> There is no need for additional permissions: you can start
Congrats, Danny!
Best,
Yuxin
Guowei Ma 于2022年11月1日周二 16:36写道：
> Congratulations Danny!
> Best,
> Guowei
>
>
> On Tue, Nov 1, 2022 at 2:20 PM weijie guo
> wrote:
>
> > Congratulations Danny!
> >
> > Best regards,
> >
> > Weijie
> >
> >
> > Maximilian Michels 于2022年10月13日周四 21:41写道：
> >
> > >
Congrats! Glad to hear that.
Best,
Yuxin
weijie guo 于2022年10月31日周一 11:51写道：
> Congratulations, this is a version with many new features and thanks to
> everyone involved!
>
> Best regards,
>
> Weijie
>
>
> Yun Tang 于2022年10月31日周一 11:32写道：
>
> > Congratulations, and thanks to everyone
Yuxin Tan created FLINK-29329:
-
Summary: Checkpoint can not be triggered if encountering OOM
Key: FLINK-29329
URL: https://issues.apache.org/jira/browse/FLINK-29329
Project: Flink
Issue Type
Caizhi, Congratulations!
Best,
Yuxin
Jane Chan 于2022年9月9日周五 10:09写道：
> Congrats Caizhi
>
> Best,
> Jane
>
> On Fri, Sep 9, 2022 at 9:58 AM Xingbo Huang wrote:
>
> > Congratulations Caizhi
> >
> > Best,
> > Xingbo
> >
> > Jingsong Lee 于2022年9月9日周五 09:41写道：
> >
> > > Hi everyone,
> > >
> > >
Congratulations, Lijie!
Best,
Yuxin
Guowei Ma 于2022年8月17日周三 18:42写道：
> Congratulations, Lijie. Welcome on board~!
> Best,
> Guowei
>
>
> On Wed, Aug 17, 2022 at 6:25 PM Zhu Zhu wrote:
>
> > Hi everyone,
> >
> > On behalf of the PMC, I'm very happy to announce Lijie Wang as
> > a new Flink
Yuxin Tan created FLINK-28942:
-
Summary: Deadlock may occurs when releasing readers for
SortMergeResultPartition
Key: FLINK-28942
URL: https://issues.apache.org/jira/browse/FLINK-28942
Project: Flink
Yuxin Tan created FLINK-28828:
-
Summary: Sorting all unfinished readers in batches at one time in
SortMergeResultPartitionReadScheduler
Key: FLINK-28828
URL: https://issues.apache.org/jira/browse/FLINK-28828
Yuxin Tan created FLINK-28826:
-
Summary: Avoid notifying too frequently when recycling buffers for
BatchShuffleReadBufferPool
Key: FLINK-28826
URL: https://issues.apache.org/jira/browse/FLINK-28826
Yuxin Tan created FLINK-28823:
-
Summary: Enlarge the max requested buffers for
SortMergeResultPartitionReadScheduler
Key: FLINK-28823
URL: https://issues.apache.org/jira/browse/FLINK-28823
Project: Flink
Yuxin Tan created FLINK-28446:
-
Summary: Expose more information in PartitionDescriptor to support
more optimized Shuffle Service
Key: FLINK-28446
URL: https://issues.apache.org/jira/browse/FLINK-28446
Congratulations, Yuan!
Best,
Yuxin
Yang Wang 于2022年3月15日周二 15:00写道：
> Congratulations, Yuan!
>
> Best,
> Yang
>
> Lincoln Lee 于2022年3月15日周二 13:32写道：
>
> > Congratulations, Yuan!
> >
> > Best,
> > Lincoln Lee
> >
> >
> > godfrey he 于2022年3月15日周二 09:53写道：
> >
> > > Congratulations, Yuan!
> > >
101 - 181 of 181 matches
Mail list logo
