Re: [Vote] PIP-220 TransferShedder (only for PIP-192 New Broker Load Balancer)

2022-11-18 Thread Baozi
+1 (non-binding) Thanks, Baodi Shi > 2022年11月18日 17:02,Enrico Olivelli 写道: > > +1 (binding) > > Enrico > > Il giorno ven 18 nov 2022 alle ore 08:34 PengHui Li > ha scritto: >> >> +1 >> >> Penghui >> >> On Fri, Nov 18, 2022 at 1:40 AM Matteo Merli wrote: >> >>> +1 >>> >>> >>> -- >>> Ma

Re: [DISCUSS] PIP-166: Function add NONE delivery semantics

2022-05-31 Thread Baozi
rint when the variable is not > set? > > 5. Regarding Test Plan > * I would add: Validate the test of autoAck=false still works (you haven't > broken anything) > * I would add: Validate existing ProcessingGuarantee test for AtMostOnce, > AtLeastOnce, ExactlyOnce still wo

Re: [DISCUSS] PIP-166: Function add NONE delivery semantics

2022-05-30 Thread Baozi
then delete it. >>> 2. For `PulsarSinkAtLeastOnceProcessor` and >>> `PulsarSinkEffectivelyOnceProcessor`, if `NONE` is configured, it defaults >>> to ATLEAST_ONCE. >>> 3. Need to let users know the behavior when they call `record.ack()` inside >>> the fun

Re: [DISCUSS] PIP-166: Function add NONE delivery semantics

2022-05-30 Thread Baozi
the following 2~3 release. And > then delete it. > 2. For `PulsarSinkAtLeastOnceProcessor` and > `PulsarSinkEffectivelyOnceProcessor`, if `NONE` is configured, it defaults > to ATLEAST_ONCE. > 3. Need to let users know the behavior when they call `record.ack()` inside > the function im

Re: [DISCUSS] PIP-166: Function add NONE delivery semantics

2022-05-30 Thread Baozi
it in the code. >>> And documented clearly it's deprecated for the following 2~3 release. And >>> then delete it. >>> 2. For `PulsarSinkAtLeastOnceProcessor` and >>> `PulsarSinkEffectivelyOnceProcessor`, if `NONE` is configured, it defaults >>> to ATLEAST_

[DISCUSS] PIP-166: Function add NONE delivery semantics

2022-05-12 Thread Baozi
Hi Pulsar community, I open a https://github.com/apache/pulsar/issues/15560 for Function add NONE delivery semantics Let me know what you think. Thanks, Baodi Shi ## Motivation Currently Function supports three delivery semantics, and also provides autoAck to control whether to automatical

Re: [DISCUSSION] PIP-156: Enable system topic by default

2022-05-11 Thread Baozi
+1 Thanks, Baodi Shi > 2022年5月11日 16:0956,Enrico Olivelli 写道: > > +1 (binding) > > Enrico > > Il giorno mer 11 mag 2022 alle ore 08:28 Zixuan Liu > ha scritto: >> >> +1(non-binding) >> >> Thanks, >> Zixuan >> >> On 2022/04/26 12:07:32 guo jiwei wrote: >>> Hi community: >>> In PIP-39 >>>

Re: [DISCUSS] Cancel the configuration of autoAck in Function framework

2022-05-09 Thread Baozi
l website document is:Whether or not the framework acknowledges messages automatically. For users, sink is also part of the function framework. Thanks, Baodi Shi > 2022年5月10日 09:1407,Baozi 写道: > > Thanks for this detailed discussion about processing guarantee and ack. > These two set

Re: [DISCUSS] Cancel the configuration of autoAck in Function framework

2022-05-09 Thread Baozi
when USER sets > ATLEAST_ONCE/EFFECTIVELY_ONCE and AUTO_ACK=true. I don't think the > JavaInstanceRunnable can ack for use under these cases. So there should be > some check to ban user submit function with such configs. > > > > On 2022/05/09 09:02:12 Baozi wrote: >&

[DISCUSS] Cancel the configuration of autoAck in Function framework

2022-05-09 Thread Baozi
Hi, guys: I found out that autoAck configuration in function framework now affects Delivery semantics, and make it difficult for users to understand. Refer to the following two scenarios. 1. If the user understands that the semantics of Guarantees shall prevail If the user set Guarantees == AT

Re: [ANNOUNCE] new Committer Qiang Zhao (mattisonchao)

2022-05-04 Thread Baozi
Congrats ! Thanks, Baozi > 2022年5月5日 08:4032,PengHui Li 写道: > > Congrats

Re: [DISUSS] Improve unit test stability

2022-03-08 Thread Baozi
ll tests by default. What's the reason? >> >> Test retries are enabled precisely because some tests are flaky. >> >> Thanks, >> Michael >> >> >> On Tue, Mar 8, 2022 at 7:57 AM Baozi >> wrote: >>> >>> Good job! >>

Re: [DISUSS] Improve unit test stability

2022-03-08 Thread Baozi
Good job! I see. Now we retry all tests by default. What's the reason? The process I understand is: We don't need to retry the unit test. Once the test fails, let the job fail. The difference is that new or modified tests need to be tested many times. As long as there is one failure, the job wi

Re: [DISUSS] Improve unit test stability

2022-03-07 Thread Baozi
Thank for your reply. I have some different viewpoint. Please have a look. > I am not sure that this helps. > You can still be very lucky and unfortunately many times the impact is on > other tests, not the new tests. Yes, that cannot avoid other unit tests affected by this PR. However, the stab