+1 (binding)
Thanks Lorenzo.
Hong
> On 20 Sep 2023, at 17:49, Danny Cranmer wrote:
>
> +1 binding.
>
> Thanks for picking this up Lorenzo!
>
> Danny
>
>
>> On Wed, 20 Sept 2023, 16:33 Jing Ge, wrote:
>>
>> +1(binding) Thanks!
>>
>
+1 (binding)
Hong
> On 26 Jun 2024, at 12:27, Keith Lee wrote:
>
> +1 (non binding)
>
> Best regards
> Keith Lee
>
>
>> On Wed, Jun 26, 2024 at 9:48 AM Zakelly Lan wrote:
>> +1 (binding)
>> Best,
>> Zakelly
>>> On Wed, Jun 26
Congratulations Xuannan!
Hong
> On 17 Aug 2024, at 17:56, Samrat Deb wrote:
>
> congratulations Xuannan Su !
>
> Bests,
> Samrat
>
>> On Sat, Aug 17, 2024 at 9:15 PM Qingsheng Ren wrote:
>>
>> Congratulations and welcome, Xuannan!
>>
>>
Huge +1 (non-binding) to this! Sad that I was late to this thread, but I agree
completely with what has been said around keeping stale PRs breeding inaction!
Thank you Tom for driving this.
Hong
> On 7 Jan 2025, at 23:30, Tom Cooper wrote:
>
> Thanks for the votes everyone. Summ
into
Proposer do something, or Reviewer do something. Stale PR bot puts the onus on
the Proposer to do something. I wonder if we should create a label like “Needs
Reviewer” to help filter PRs that are currently waiting for Reviewer, so
Reviewers can easily filter PRs where we do something!
Hong
of metrics!
I think you might be referring to the metrics of the Flink job itself (e.g. CPU
/ memory metrics). For this use case, I would agree that we should not use this
sink but instead use our metric reporters.
Regards,
Hong
> On 16 May 2023, at 03:37, Lijie Wang wrote:
>
>
, does the
SplitEnumerator re-take the snapshot of state for a checkpoint if an
OperatorEvent is sent before the checkpoint is complete?
Regards,
Hong
serialisers to be a Flink-specific serialisation exception
instead of IllegalStateException [2]
Any thoughts on the above?
Regards,
Hong
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-304%3A+Pluggable+Failure+Enrichers
[2] https://lists.apache.org/thread
That would be true for events sent from Coordinator -> Subtask, but not from
Subtask -> Coordinator.
I will work with those active on [1] to resolve this situation! Any feedback is
welcome!
Regards,
Hong
[1] https://issues.apache.org/jira/browse/FLINK-26029
[2]
https://github.com/apache/f
That would be true for events sent from Coordinator -> Subtask, but not from
Subtask -> Coordinator.
I will work with those active on [1] to resolve this situation! Any feedback is
welcome!
Regards,
Hong
[1] https://issues.apache.org/jira/browse/FLINK-26029
[2]
https://github.com/apache/f
That would be true for events sent from Coordinator -> Subtask, but not from
Subtask -> Coordinator.
I will work with those active on [1] to resolve this situation! Any feedback is
welcome!
Regards,
Hong
[1] https://issues.apache.org/jira/browse/FLINK-26029
[2]
https://github.com/apache/f
. We could address this by
wrapping the existing exception rather than replacing.
@Panagiotis
I agree with all your points. This proposal is in synergy with Pluggable
Failure Enrichers.
Regards,
Hong
> On 6 Jun 2023, at 06:50, Panagiotis Garefalakis wrote:
>
> CAUTION: This email o
d happens
before the record is written to the Kinesis Sink.
Hope the above clarifies your question!
Regards,
Hong
On 14 Jun 2023, at 19:27, Lu Niu wrote:
CAUTION: This email originated from outside of the organization. Do not click
links or open attachments unless you can confirm the sender and
lar. However, I think the end use-case is different. For
example, AsyncSink might want to implement support for some form of
2phase-commit on Sink (at least once guarantee). This is slightly more
complicated on AsyncFunction.
Regards,
Hong
On 15 Jun 2023, at 00:26, Lu Niu wrote:
CAUT
hearing people’s thoughts.
Regards,
Hong
s could get quite complicated.
I like that it uses the industry standards, but I agree, we need to think
carefully about the multiple layers of cache we have included in the Flink JM.
Will take a look at this.
Let me know your thoughts!
Regards,
Hong
> On 26 Jun 2023, at 13:26, David Mor
/apache/flink-connector-aws/blob/main/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkWriter.java#L169-L171
Regards,
Hong
> On 26 Jun 2023, at 03:52, Jark Wu wrote:
>
> CAUTION: This email originated from outside of the organization. Do
Thanks Xintong for driving the effort.
I’d add a +1 to reworking configs, as suggested by @Jark and @Chesnay,
especially the types. We have various configs that encode Time / MemorySize
that are Long instead!
Regards,
Hong
> On 29 Jun 2023, at 16:19, Yuan Mei wrote:
>
> CAUT
/C03GV7L3G2C/p1688051972688149
[2] https://lists.apache.org/thread/7o330hfyoqqkkrfhtvz3kp448jcspjrm
Regards,
Hong
Just adding the updates from the Slack thread -
@SamratDeb and @JulietLee have expressed interest, and there is a PR ready for
review!
https://github.com/apache/flink/pull/22901
Regards,
Hong
On 3 Jul 2023, at 16:56, Teoh, Hong wrote:
CAUTION: This email originated from outside of the
+1 to this. Nice to simplify the REST API!
Regards,
Hong
> On 18 Jul 2023, at 10:00, Chesnay Schepler wrote:
>
> Something to note is that the UI is using this parameter, and would have to
> be changed to the new one.
>
> Since we want to avoid having to split arguments o
/1ztEoyGkqq9ie5riQxRtMuBu3vb6BUO91mSMn1PU0pDA/edit#heading=h.vhcuqlttpnog
Side question: Does anyone know why we have libraries that use the non-vendored
guava version? [6]
[6]
https://github.com/search?q=repo%3Aapache%2Fbeam%20library.java.guava&type=code
Regards,
Hong
Sorry - meant to send this to a different mailing list -.-
> On 31 Jul 2023, at 15:58, Hong Teoh wrote:
>
> Hi all,
>
> The current version of guava that is vendored in Beam is
> com.google.guava:guava:26.0-jre.
>
> This version is really old, and has active vuln
+1 (binding)
Thanks Deepthi!
On Thu, Aug 3, 2023 at 7:44 PM Danny Cranmer
wrote:
> +1 (binding)
>
> Thanks Deepthi
>
>
> On Thu, 3 Aug 2023, 12:03 Rui Fan, <1996fan...@gmail.com> wrote:
>
> > +1(binding), thanks for driving this proposal, it's cool !
> >
> > Best,
> > Rui Fan
> >
> > On Thu,
Congratulations Matthias!
Very well deserved!
Regards,
Hong
On Fri, Aug 4, 2023 at 10:38 AM Markos Sfikas
wrote:
> Congrats Matthias!
> Best
> Markos
>
> On Fri, Aug 4, 2023 at 11:25 AM Alexander Fedulov <
> alexander.fedu...@gmail.com> wrote:
>
> > Congrats!
+1. Thanks Jing for driving this.
Hong
On Mon, Dec 11, 2023 at 2:27 AM Yun Tang wrote:
> Thanks Jing for driving 1.18.1 release, +1 for this.
>
>
> Best
> Yun Tang
>
> From: Rui Fan <1996fan...@gmail.com>
> Sent: Saturday, De
successfully to the sink table.
* Verified sink metrics look ok.
Cheers,
Hong
On 28/11/2022, 16:44, "Danny Cranmer" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unless you can confirm the sender and know the
conte
connectors work:
* flink-sql-connector-aws-kinesis-firehose
* flink-sql-connector-aws-kinesis-streams
* flink-sql-connector-kinesis
Cheers,
Hong
On 06/12/2022, 17:41, "Danny Cranmer" wrote:
CAUTION: This email originated from outside of the organization. Do not
click lin
versions more easily.
2. We can now move flink-connector-aws-base to the external repository as
well.
Regards,
Hong
. We could consider proposing a separate lifecycle
management for Flink plugins.
Regards,
Hong
On 24/01/2023, 14:46, "Danny Cranmer" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unless you can confirm the sender a
now move flink-connector-aws-base to the external repository as well.
Voting Schema:
Consensus, committers have binding votes, open for at least 72 hours.
Thanks,
Hong
[1] https://lists.apache.org/thread/03l99yz62mq3ngj8cvg8stk4foym65jq
[2] https://github.com/apache/flink-connector-aws/
+1 (non-binding)
* Hashes and Signatures look good
* All required files on dist.apache.org
* Source archive builds using maven
* Started packaged example WordCountSQLExample job.
Cheers,
Hong
On 27/01/2023, 07:52, "Gabor Somogyi" wrote:
CAUTION: This email originated from
I propose that we:
- Mark the inherently public classes in flink-avro as @PublicEvolving
- Proceed with externalizing flink-avro-glue-schema-registry
Let me know what you think!
Regards,
Hong
[1] AvroInputFormat
https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastre
sation of the
flink-avro-glue-schema-registry module, because we need to ensure backwards
compatibility with our work (i.e. the shape should not change incompatibly).
Feel free to start another thread on discussing Public APIs in general if there
are more questions!
Regards,
Hong
On 31/01/2023,
Got it. Thanks for flagging it up.
I have created a JIRA for the followup to make flink-avro Public API more
clear. https://issues.apache.org/jira/browse/FLINK-30853
Will close this vote thread and announce in a separate thread.
Regards,
Hong
Hi Dong Lin,
I see where you are coming from. I agree it would be good to have a FLIP to
design the public API for flink-avro, so we will limit this vote thread to the
externalization.
Regards,
Hong
From: Dong Lin
Date: Tuesday, 31 January 2023 at 14:26
To: "dev@flink.apache.org
-binding)
* Dong Lin (binding)
Regards,
Hong
Thanks Danny for driving this
+1 (non-binding)
* Hashes and Signatures look good
* All required files on dist.apache.org
* Source archive builds using maven
* Started packaged example WordCountSQLExample job
* Web PR looks good.
Cheers,
Hong
> On 24 Feb 2023, at 05:36, Weihua Hu wr
tly?
- independent vs ordered execution: Should we consider making the order of
execution deterministic (use a List instead of Set)?
Once again, thank you for working on this.
Regards,
Hong
> On 21 Mar 2023, at 21:07, Jing Ge wrote:
>
> Hi,
>
> Thanks Panagiotis for this FLIP
+1 (non-binding)
* Hashes and Signatures look good
* All required files on dist.apache.org
* Tag is present in Github
* Verified source archive does not contain any binary files
* Source archive builds using maven
Cheers,
Hong
> On 22 Mar 2023, at 07:21, Robert Metzger wrote:
>
>
+1 (non-binding)
* Hashes and Signatures look good
* All required files on dist.apache.org
* Tag is present in Github
* Verified source archive does not contain any binary files
* Source archive builds using maven
Cheers,
Hong
> On 28 Mar 2023, at 12:56, Samrat Deb wrote:
>
> CAUT
Hi Dong and Zhipeng,
Thanks for starting the discussion. Glad to see a new release of Flink ML.
Cheers!
On Fri, Mar 31, 2023 at 2:34 PM Zhipeng Zhang
wrote:
> Hi Dong,
>
> Thanks for starting the discussion. +1 for the Flink ML 2.1.0 release.
>
for 1 timeout
for all failure handlers.
2. +1 to Zhu’s comment on adding a comma separated list of FailureHandlers
instead of boolean toggle!
Other than the above, the FLIP looks great! Thank you for your efforts.
Regards,
Hong
> On 11 Apr 2023, at 08:01, Zhu Zhu wrote:
>
> CAUT
Thanks Danny
+1 (non-binding)
* Hashes and Signatures look good
* All required files on dist.apache.org
* Tag is present in Github
* Verified source archive does not contain any binary files
* Source archive builds using maven
Cheers,
Hong
> On 14 Apr 2023, at 06:36, Elphas Toringepi wr
Thanks Danny
+1 (non-binding)
* Hashes and Signatures look good
* All required files on dist.apache.org
* Tag is present in Github
* Verified source archive does not contain any binary files
* Source archive builds using maven
Cheers,
Hong
> On 14 Apr 2023, at 05:21, Elphas Toringepi wr
+1 (non-binding)
Thank you for driving this effort, Panagiotis.
Regards,
Hong
> On 20 Apr 2023, at 12:16, David Morávek wrote:
>
> Thanks for the update!
>
> +1 (binding)
>
> Best,
> D.
>
> On Thu, Apr 20, 2023 at 9:50 AM Piotr Nowojski wrote:
>
>
flink-shaded, which is relocated to keep the
usage of libraries contained within the flink runtime itself, I am inclined
to go with Option 1, even though the change is slightly larger than just
the security fixes.
Do people have any objections?
Regards,
Hong
[1] https://nvd.nist.gov/vuln/detail
+1 (binding)
Thank you for driving this Emre! This is a good step towards better user
experience when diagnosing performance issues with Flink jobs.
Best,
Hong
On Wed, Jan 31, 2024 at 3:00 AM Aleksandr Pilipenko
wrote:
> Thanks for the FLIP!
>
> +1 (non-binding)
>
> Best,
>
+1 (binding)
Thanks Priya for driving this! This has been a requested feature for a
while now, and will benefit the community :)
Hong
On Tue, Apr 16, 2024 at 3:23 AM Muhammet Orazov
wrote:
> +1 (non-binding)
>
> Thanks Priya for the FLIP and driving it!
>
> Best,
> Muhammet
feature flag to determine if we
should be using this new native file copy support.
2/ Configure the location of the s5cmd binary (version control etc.), as
you have mentioned in the FLIP.
Regards,
Hong
On Thu, May 2, 2024 at 9:40 AM Muhammet Orazov
wrote:
> Hey Piotr,
>
> Thank
Hi Priya,
Great to see the FLIP has passed the vote.
It would be good to report the final result of the vote at the end of the
thread, listing the binding / non-binding votes in an email. See example
here [1] [2]
Regards,
Hong
[1] https://lists.apache.org/thread/3sj88kk0104vzj4hklfgbn3rpdnjxj8v
Hi Ahmed,
Thanks for putting this together! Should we still be marking
getFatalExceptionCons() as @Deprecated in this FLIP, if we are not
providing a replacement?
Regards,
Hong
On Mon, May 13, 2024 at 7:58 PM Ahmed Hamdy wrote:
> Hi David,
> yes there error classification was initially l
+1 (binding)
Thanks Ahmed
On Tue, May 14, 2024 at 11:51 AM David Radley
wrote:
> Thanks for the clarification Ahmed
>
> +1 (non-binding)
>
> From: Ahmed Hamdy
> Date: Monday, 13 May 2024 at 19:58
> To: dev@flink.apache.org
> Subject: [EXTERNAL] Re: [VOTE] FLIP-451: Introduce timeout configura
reate this new patch release, I'm happy to
volunteer as the release manager, if another PMC (Danny?) is happy to
assist with the PMC-related release steps!
Best regards,
Hong
[1]
https://issues.apache.org/jira/projects/FLINK/versions/12354399
[2]
https://issues.apache.org/jira/issues/?jql=pro
bsite pull request listing the new release and adding announcement blog
post [6].
The vote will be open for at least 72 hours. It is adopted by majority
approval, with at least 3 PMC affirmative votes.
Thanks,
Hong
[1]
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&versi
n 1 more
binding vote!
Regards,
Hong
On Sat, Jun 8, 2024 at 11:33 PM Ahmed Hamdy wrote:
> Hi Hong,
> Thanks for driving
>
> +1 (non-binding)
>
> - Verified signatures and hashes
> - Checked github release tag
> - Verified licenses
> - Checked that the source code doe
Pohl (binding)
* Sergey Nuyanzin (non-binding)
* Leonard Xu (binding)
* Zhongqiang Gong (non-binding)
* Hang Ruan (non-binding)
There are no disapproving votes.
Thanks everyone!
[1] https://lists.apache.org/thread/hrptj22y6rjt61flzdzngxdsw134osk4
Regards,
Hong
Thanks all for the testing and votes.
The RC is approved and this thread is now closed. See results in [1].
[1] https://lists.apache.org/thread/yqr3jv4wr85brnz2ylzqo9pqn453jqvq
Regards,
Hong
On Tue, Jun 11, 2024 at 9:39 AM Hang Ruan wrote:
> +1(non-binding)
>
> - Verified s
with feedback on the release process. Our goal is to constantly improve the
release process. Feedback on what could be improved or things that didn't
go so well are appreciated.
Regards,
Hong
Congratulations, Yuan!
Best,
Zhilong
On Mon, Mar 14, 2022 at 7:22 PM Konstantin Knauf wrote:
> Congratulations, Yuan!
>
> On Mon, Mar 14, 2022 at 11:29 AM Jing Zhang wrote:
>
> > Congratulations, Yuan!
> >
> > Best,
> > Jing Zhang
> >
> > Jing Ge 于2022年3月14日周一 18:15写道：
> >
> > > Congrats! Ver
Records API request on your Kinesis
Stream
https://docs.aws.amazon.com/athena/latest/ug/cloudtrail-logs.html
Regards,
Hong
On 25/05/2022, 11:30, "Ahmed Hamdy" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unles
Congratulations, Ingo!
Best,
Zhilong
On Wed, Dec 8, 2021 at 10:18 PM godfrey he wrote:
> Congratulations, Ingo!
>
> Best,
> Godfrey
>
> Roman Khachatryan 于2021年12月6日周一 下午6:07写道：
> >
> > Congratulations, Ingo!
> >
> > Regards,
> > Roman
> >
> >
> > On Mon, Dec 6, 2021 at 11:05 AM Yang Wang wro
Congratulations, Matthias!
Best,
Zhilong
On Wed, Dec 8, 2021 at 10:18 PM godfrey he wrote:
> Congratulations, Matthias!
>
> Best,
> Godfrey
>
> Roman Khachatryan 于2021年12月6日周一 下午6:07写道：
> >
> > Congratulations, Matthias!
> >
> > Regards,
> > Roman
> >
> >
> > On Mon, Dec 6, 2021 at 11:04 AM Ya
Thank you for proposing this improvement, Wenhao. Changing the logging
level dynamically at runtime is very useful when users are trying to debug
their jobs. They can set the logging level to DEBUG and find out more
details in the logs.
1. I'm wondering if we could add a REST API to query the curr
Hi, Chengyun:
Thanks for your passion for contributing to the Flink community. You don't
need a contributor permission to contribute your code to Flink. Find an
open issue you are interested in at
http://issues.apache.org/jira/browse/FLINK and comment with your ideas. It
would be a good start for
Thank you for everything, Till! I've learned a lot from you.
Good luck with your new adventure and the next chapter!
Best,
Zhilong
On Tue, Mar 1, 2022 at 12:08 PM Yun Tang wrote:
> Thanks a lot for your efforts and kindness of mentoring contributors in
> Apache Flink community, Till!
>
> Good
Congratulations, Martin! Well deserved!
Best,
Zhilong
On Sat, Mar 5, 2022 at 1:09 AM Piotr Nowojski wrote:
> Congratulations!
>
> Piotrek
>
> pt., 4 mar 2022 o 16:05 Aitozi napisał(a):
>
> > Congratulations Martjin!
> >
> > Best,
> > Aitozi
> >
> > Martijn Visser 于2022年3月4日周五 17:10写道：
> >
> >
Congratulations, David!
Best,
Zhilong
On Sat, Mar 5, 2022 at 1:09 AM Piotr Nowojski wrote:
> Congratulations :)
>
> pt., 4 mar 2022 o 16:04 Aitozi napisał(a):
>
> > Congratulations David!
> >
> > Ingo Bürk 于2022年3月4日周五 22:56写道：
> >
> > > Congrats, David!
> > >
> > > On 04.03.22 12:34, Robert
Hello, everyone:
I would like to start the discussion about FLINK-21110: Optimize Scheduler
Performance for Large-Scale Jobs [1].
According to the result of scheduler benchmarks we implemented in FLINK-20612
[2], the bottleneck of deploying and running a large-scale job in Flink is
mainly focu
Congratulations, Xintong!
Dawid Wysakowicz 于2021年6月16日周三 下午5:23写道：
> Hi all!
>
> I'm very happy to announce that Xintong Song has joined the Flink PMC!
>
> Congratulations and welcome Xintong!
>
> Best,
> Dawid
>
Congratulations, Guowei!
Best,
Zhilong
On Tue, Jul 6, 2021 at 10:01 PM Kurt Young wrote:
> Hi all!
>
> I'm very happy to announce that Guowei Ma has joined the Flink PMC!
>
> Congratulations and welcome Guowei!
>
> Best,
> Kurt
>
Hi, Pang!
Thank you for your enthusiasm for contribution. You don't need any
permission to contribute codes to Apache Flink. Feel free to find the
issues that you are interested in JIRA (
https://issues.apache.org/jira/projects/FLINK/issues). The issues with the
label "starter" is a good choice to
Congratulations, Yuan!
Best,
Zhilong
On Thu, Jul 8, 2021 at 1:22 AM Yu Li wrote:
> Hi all,
>
> On behalf of the PMC, I’m very happy to announce Yuan Mei as a new Flink
> committer.
>
> Yuan has been an active contributor for more than two years, with code
> contributions on multiple components
ve.
[1]
https://docs.google.com/document/d/1L3aI9LjkcUPoM52liEY6uFktMnFMNFQ6kXAjnz_11do
Sincerely,
Fan Hong
On Fri, Aug 6, 2021 at 3:56 PM Becket Qin wrote:
> Hi Zhipeng,
>
> Yes, I agree that the key difference between the two options is how they
> support MIMO.
>
> My main
some community
convention.
I also would like to mention the same issue exists in Proposal 1, as there
are also multiple places where developers can implement algorithms.
In summary, I think the first and second issue above are
preference-related, and hope my thoughts can give some clues. The third
Congratulations, Leonard!
On Mon, Nov 15, 2021 at 10:13 AM Qingsheng Ren wrote:
> Congratulations Leonard!
>
> --
> Best Regards,
>
> Qingsheng Ren
> Email: renqs...@gmail.com
> On Nov 12, 2021, 12:12 PM +0800, Jark Wu , wrote:
> > Hi everyone,
> >
> > On behalf of the PMC, I'm very happy to ann
Congratulations, Yangze!
On Mon, Nov 15, 2021 at 10:13 AM Qingsheng Ren wrote:
> Congratulations Yangze!
>
> --
> Best Regards,
>
> Qingsheng Ren
> Email: renqs...@gmail.com
> On Nov 12, 2021, 10:11 AM +0800, Xintong Song ,
> wrote:
> > Hi everyone,
> >
> > On behalf of the PMC, I'm very happy t
Congratulations, Fabian!
Best regards,
Zhilong Hong
On Tue, Nov 16, 2021 at 10:19 AM Yangze Guo wrote:
> Congrats & well deserved!
>
> Best,
> Yangze Guo
>
> On Tue, Nov 16, 2021 at 10:18 AM Jing Zhang wrote:
> >
> > Congratulations Fabian!
> >
> &g
Congratulations, Jing!
Best regards,
Zhilong Hong
On Mon, Nov 15, 2021 at 9:41 PM Martijn Visser
wrote:
> Congratulations Jing!
>
> On Mon, 15 Nov 2021 at 14:39, Timo Walther wrote:
>
> > Hi everyone,
> >
> > On behalf of the PMC, I'm very happy to ann
Congratulations, Yiingjie!
Best regards,
Zhilong
On Wed, Nov 17, 2021 at 2:13 PM Yuepeng Pan wrote:
> Congratulations !
>
>
> Best,
> Yuepeng Pan.
>
>
> At 2021-11-17 12:55:29, "Guowei Ma" wrote:
> >Hi everyone,
> >
> >On behalf of the PMC, I'm very happy to announce Yingjie Cao as a new
> Fl
Thank you! __
Hong
On 18/06/2022, 15:11, "Jing Ge" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unless you can confirm the sender and know the
content is safe.
Hi,
Your access will be granted next w
FLIP-242 [2]. Looking forward to your feedback!
[1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink
[2]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-242%3A+Introduce+configurable+CongestionControlStrategy+for+Async+Sink
Regards,
Hong
Congratulations, Qingsheng and ShengKai!
Best,
Zhilong.
On Mon, Jun 20, 2022 at 4:00 PM Lijie Wang wrote:
> Congratulations, Qingsheng and ShengKai.
>
> Best,
> Lijie
>
> Paul Lam 于2022年6月20日周一 15:58写道：
>
> > Congrats, Qingsheng and Shengkai!
> >
> > Best,
> > Paul Lam
> >
> > > 2022年6月20日 15:
Thank you!
On 19/06/2022, 11:59, "Jing Ge" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unless you can confirm the sender and know the
content is safe.
Hi Hong,
you should now have the access. Looki
nk that would be bloating the responsibility of the
RateLimitingStrategy a little too much. What do you think?
Regards,
Hong
On 23/06/2022, 10:05, "Piotr Nowojski" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unl
(maxBufferedRequests)
Yes you are right. It would be more appropriately named maxBufferedMessages or
maxBufferedRequestEntries. However, these names are internal, so we can rename
it appropriately.
Regards,
Hong
On 24/06/2022, 17:07, "Piotr Nowojski" wrote:
CAUTION: This email
equests currently in
flight. `maxBufferedRequests` on the other hand measures how many messages are
in the AsyncSinkWriter’s buffer (or queue). We flush when the number of
buffered messages > ` maxBufferedRequests`.
Regards,
Hong
From: Piotr Nowojski
Date: Monday, 27 June 2022 at 08:22
ible for us. All in all +1 for your current
> proposal.
Ok, let’s keep it separate for now since the complexity is encapsulated in the
AsyncSinkWriter.
Regards,
Hong
From: Piotr Nowojski
Date: Monday, 27 June 2022 at 09:27
To: "Teoh, Hong"
Cc: "dev@flink.apache.org
/k5s970xlqoj7opx1pzbpylxcov0tp842
[2]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-242%3A+Introduce+configurable+RateLimitingStrategy+for+Async+Sink
Regards,
Hong
+Introduce+configurable+RateLimitingStrategy+for+Async+Sink
[2] https://lists.apache.org/thread/9z3nfgv57g4cmwcl90r4h5tct9h2qgvv
Regards,
Hong
Hi all,
I'd also like to add my non-binding +1 for this FLIP. I think it's a great idea
to make onboarding easier for new data analysts/engineers, and IMO adding more
dedicated connectors is a step in the right direction.
Regards,
Hong
On 27/07/2022, 19:15, "Ryan
That way we can change the flink configuration override behaviour
without restarting the Flink cluster. This would make sense if we are thinking
of a Session cluster and deploying multiple Flink jobs to the same cluster.
Regards,
Hong
On 18/08/2022, 10:46, "Danny Cranmer" wrote:
etups
Regards,
Hong
On 18/08/2022, 11:38, "Gyula Fóra" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unless you can confirm the sender and know the
content is safe.
+1 for the proposal.
@Hong :
if we can update the Flink docs on configuration
(https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/)
to specify which configuration is "cluster" and which is "job".
Regards,
Hong
On 20/08/2022, 09:16, "Zheng Yu Chen" wrote:
we set it such that the
"rest.submit.job.override-config" cannot be overwritten in user code (ignored),
just like configuration "jobmanager.rpc.port"?
What do you think?
Regards,
Hong
On 26/08/2022, 12:05, "Zheng Yu Chen" wrote:
CAUTION: This email originated fr
That sounds good to me. Thanks for working in this Zheng Yu!
Hong
From: Zheng Yu Chen
Sent: 01 September 2022 05:08:03
To: dev@flink.apache.org
Subject: RE: [EXTERNAL][DISCUSS] FLIP-256 Support Job Dynamic Parameter With
Flink Rest Api
CAUTION: This
+1 (non-binding)
Thanks for driving this!
Regards,
Hong
On 11/09/2022, 19:23, "Gyula Fóra" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unless you can confirm the sender and know the
content is safe.
+
streaming. Looks ok
* Added a couple of nits to the release PR
Cheers,
Hong
On 04/10/2022, 12:56, "Matthias Pohl" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unless you can confirm the sender and know the
conte
Congratulations Danny!
Hong
On 10/10/2022, 08:06, "Robert Metzger" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unless you can confirm the sender and know the
content is safe.
Hi everyone,
I'm
streaming with checkpointing enabled. Looks ok
Cheers,
Hong
On 24/10/2022, 16:06, "Gyula Fóra" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unless you can confirm the sender and know the
content is safe.
+
1 - 100 of 281 matches
Mail list logo
