Re: Need help with finding inner workings of watermark stream idleness

2022-02-02 Thread Jeff Carter
at > this is fairly deep into the runtime stack. > > Seth > > On Tue, Feb 1, 2022 at 2:34 PM Jeff Carter wrote: > > > Thanks, Till. > > > > That definitely helps a bit. I'm still not seeing where there is some > idle > > variable that the output.mark

Re: Need help with finding inner workings of watermark stream idleness

2022-02-01 Thread Jeff Carter
/WatermarksWithIdleness.java#L73 > > Cheers, > Till > > On Tue, Jan 11, 2022 at 6:05 PM Jeff Carter wrote: > > > I'm looking into making a feature for flink related to watermarks and am > > digging into the inner watermark mechanisms, specifically with idleness.

Need help with finding inner workings of watermark stream idleness

2022-01-11 Thread Jeff Carter
I'm looking into making a feature for flink related to watermarks and am digging into the inner watermark mechanisms, specifically with idleness. I'm familiar with idleness, but digging into the root code I can only get to where idlenessTimeout gets set in WatermarkStrategyWithIdleness.java. But

Re: [DISCUSS] Dropping flink-storm?

2018-09-28 Thread Jeff Carter
+1 to drop it. On Fri, Sep 28, 2018, 7:25 PM Hequn Cheng wrote: > Hi, > > +1 to drop it. It seems that few people use it. > > Best, Hequn > > On Fri, Sep 28, 2018 at 10:22 PM Chesnay Schepler > wrote: > > > I'm very much in favor of dropping it. > > > > Flink has been continually growing in ter

Re: Am I forgetting to do something to get pull request accepted?

2018-06-21 Thread Jeff Carter
Ok, thanks! On Thu, Jun 21, 2018, 1:18 AM Chesnay Schepler wrote: > The Flink project currently receives too many pull requests / has to few > reviewers to ensure timely reviews. > > I assume you are talking about https://github.com/apache/flink/pull/5876 > If this is correct, something you coul