Re: [DISCUSS] Drop support for HBase v1

2024-01-31 Thread jialiang tan
Hi Martijn, Ferenc Thanks all for driving this. As Ferenc said, HBase 1.x is dead, so on the way forward it should be safe to drop it. Same view as mine. So +1 for this. Best! tanjialiang Replied Message >From Ferenc Csaky Date 1/30/2024 22:14 To Subject Re: [DISCUSS] Drop support f

Confluence access request

2024-02-26 Thread jialiang tan
Hi, devs! I want to prepare a FLIP and start a discussion on the dev mailing list, but I find I don't have the access, can someone give me access to confluence? My Confluence username: tanjialiang Best regards, tanjialiang

Re: Confluence access request

2024-02-26 Thread jialiang tan
he "Create your > Own FLIP" > part, thank you. > > [1] https://lists.apache.org/thread/rkpvlnwj9gv1hvx1dyklx6k88qpnvk2t > [2] > > https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals > > Best, > Rui > > On Tue, Feb 27, 2024 at 10

[DISCUSS] FLIP-XXX Support currentFetchEventTimeLag and processingLag metrics

2024-04-22 Thread jialiang tan
Hello devs, I would like to start a discussion about FLIP-XXX: Support currentFetchEventTimeLag and processingLag metrics [1]. The main motivation for this change was that I had some difficulties in implementing the currentFetchEventTimeLag metrics for KafkaSource [2]. So I proposed to let the Sour

Re: [DISCUSS] FLIP-XXX Support currentFetchEventTimeLag and processingLag metrics

2024-04-22 Thread jialiang tan
Sorry all, it seems bad formatting in my email message, now I send it again gently and hope it work. I would like to start a discussion about FLIP-XXX: SupportcurrentFetchEventTimeLag and processingLag metrics [1]. The main motivation for this change was that I had some difficulties inimplementin

Re: [DISCUSS] FLIP-XXX Support currentFetchEventTimeLag and processingLag metrics

2024-04-24 Thread jialiang tan
s, and no change for Flink WEB UI. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-33%3A+Standardize+Connector+Metrics [2] https://lists.apache.org/thread/r47zrqto4k8tsc3xvfg392zblfx6dczl Best, TanJiaLiang 于2024年4月24日周三 15:02写道: > Hello jialiang tan, and thank you for your contribution!

Re: [DISCUSS] FLIP-XXX Support currentFetchEventTimeLag and processingLag metrics

2024-04-26 Thread jialiang tan
Millis(); > > Is this some pseudo-code or an actual implementation? > This should invoke something like `System.nanoTime()` and not > `System.currentTimeMillis()` because of precision/accuracy reasons [1] > > [1] > https://stackoverflow.com/questions/351565/system-currenttimemillis

Re: [DISCUSS] FLIP-XXX Support currentFetchEventTimeLag and processingLag metrics

2024-04-28 Thread jialiang tan
Thanks Qingsheng for the patient guidance! And sorry to everyone for wasting your time. I suddenly realised that my implementation is wrong. In my implementation the FetchTime and EventTime do not come from the same record and I am making this stupid mistake :( . I need some time to think about