Re: [streaming] Regarding loops in the job graph

2015-01-21 Thread Márton Balassi
As far as I remember when we were implementing the iteration for streaming we deliberately "went off" the jobgraph and implemented the backward edge as an in-memory hook (practically the same in batch but not blocking in the backward channel). When we asked the reasoning here on the dev list we go

Re: Question about Commit Policy

2015-01-27 Thread Márton Balassi
>> > > >>> > >> > > +1 for the guide and JIRA references. > >>> > >> > > > >>> > >> > > I'd keep the component tags optional though. > >>> > >> > >

Community vote for Hadoop Summit result

2015-01-29 Thread Márton Balassi
Hi everyone, Thanks for your support for the Flink talks at the community choice for the next Hadoop Summit Europe. The results are out. [1] Our submission "Real-Time Stream Processing with Apache Flink” [2] has been selected as the winner in the Future Hadoop track by Community Choice voting tha

Re: Community vote for Hadoop Summit result

2015-01-30 Thread Márton Balassi
ongrats guys! >> >> On Thu, Jan 29, 2015 at 4:06 PM, Márton Balassi >> wrote: >> > Hi everyone, >> > >> > Thanks for your support for the Flink talks at the community choice for >> the >> > next Hadoop Summit Europe. The results are out

Re: Question about StreamRecord.uid in flink-streaming

2015-02-05 Thread Márton Balassi
Hi, It is for the soon to come streaming fault tolerance purposes - tracking the records by the unique ID. Currently it is unused. Best, Marton On Thu, Feb 5, 2015 at 4:20 PM, Aljoscha Krettek wrote: > Hi, > why do we have that field? It seems it is not used anywhere. And then, > as a follow

Re: Planning Release 0.8.1

2015-02-06 Thread Márton Balassi
Found a streaming bug, Gyula fixed it. Pushing it soon to both master and branch-0.8. On Fri, Feb 6, 2015 at 11:51 AM, Robert Metzger wrote: > @Aljoscha, can you merge the backported fix to the "release-0.8" branch > when its ready? > > On Fri, Feb 6, 2015 at 11:39 AM, Aljoscha Krettek > wrote:

Re: Google Summer of Code 2015 is coming

2015-02-08 Thread Márton Balassi
Hey, As for streaming Gyula and myself would be available for mentors. - Integrating streaming to the webclient - Runtime monitoring for streaming - Collect method for DataSet/DataStream -> scala stream and shell integration On Sat, Feb 7, 2015 at 11:47 PM, Fabian Hueske wrote: > I think it w

Re: Planning Release 0.8.1

2015-02-09 Thread Márton Balassi
well... > > > > On Fri, Feb 6, 2015 at 12:52 PM, Aljoscha Krettek > > wrote: > > > > > @robert, yes, will do > > > > > > On Fri, Feb 6, 2015 at 12:28 PM, Márton Balassi > > > wrote: > > > > Found a streaming bug, Gyula fixed it. Pu

Re: [VOTE] Release Apache Flink 0.8.1 (RC0)

2015-02-10 Thread Márton Balassi
+1 Built from source Run local examples Checked version numbers in the poms Validated check sums and signatures Minor cosmetic thing to note: The name of flink-parent (Apache Flink) in the maven build is still not nice and the inception year is set to 2015 (should be 2014). It seems that the com

Re: Gelly is in!

2015-02-11 Thread Márton Balassi
Woot! :) On Wed, Feb 11, 2015 at 11:53 AM, Stephan Ewen wrote: > Hi everyone! > > I am happy to say that the graph library "Gelly" is finally in the code :-) > > Thanks Vasia, Daniel, Andra, and Carsten for the great work! > > Greetings, > Stephan >

Re: Google Summer of Code 2015 is coming

2015-02-12 Thread Márton Balassi
ully change after I finish my internship > > and > > > some paper deadlines pass :) > > > > > > Thanks! > > > > > > -V. > > > > > > On 8 February 2015 at 11:49, Gyula Fóra wrote: > > > > > > > Hey, > > > > >

Re: Kubernetes Operator 1.3.0 release

2022-11-29 Thread Márton Balassi
Hi all, Thanks for volunteering, Matyas and +1 for the 1.3 operator release. The modified timeline suggested by Gyula sounds good to me. On Tue, Nov 29, 2022 at 7:04 AM Őrhidi Mátyás wrote: > Thanks Gyula! Sounds good. > > On Mon, Nov 28, 2022 at 9:59 PM Gyula Fóra wrote: > > > Hi Matyas! > >

Re: [VOTE] FLIP-271: Autoscaling

2022-11-29 Thread Márton Balassi
+1 (binding) On Tue, Nov 29, 2022 at 6:13 AM Chenya Zhang wrote: > +1 (non-binding) > > On Sun, Nov 27, 2022 at 5:49 PM Jiangang Liu > wrote: > > > +1 (non-binding) > > > > Best, > > Jiangang Liu > > > > Thomas Weise 于2022年11月28日周一 06:23写道: > > > > > +1 (binding) > > > > > > > > > On Sat, Nov

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.3.0, release candidate #1

2022-12-08 Thread Márton Balassi
Thank you, Matyas. +1 (binding) - Verified Helm repo works as expected, points to correct image tag, build, version - Verified basic examples + checked operator logs everything looks as expected - Verified hashes, signatures and source release contains no binaries - Ran built-in tests, built jars

Re: [DISCUSS] Release new FRocksDB

2022-12-12 Thread Márton Balassi
Hi Yanfei, Makes sense, arm architecture support would be great. Thanks for looking into this. On Mon, Dec 12, 2022 at 3:03 PM Yanfei Lei wrote: > Hi devs, > > I'd like to bring up a discussion about releasing the new frocksdbjni > version, we are planning to adapt frocksdbjni to Apple M1 mach

Re: Flink Forward Session Question

2023-01-02 Thread Márton Balassi
Hi Rion, Unlike the previous Flink Forwards to the best of my knowledge the latest edition was not uploaded to YouTube. It might make sense to reach out to the authors directly. On Sat, Dec 31, 2022 at 5:35 PM Rion Williams wrote: > Hey Flinkers, > > Firstly, early Happy New Year’s to everyone

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.3.1, release candidate #1

2023-01-03 Thread Márton Balassi
Thank you, Gyula. +1 (binding) - Verified Helm repo works as expected, points to correct image tag, build, version - Verified basic examples + checked operator logs everything looks as expected - Verified hashes, signatures and source release contains no binaries - Ran built-in tests, built jars

Re: Proposal to add support for Kafka Headers to KafkaRecordSerializationSchemaWrapper

2023-02-13 Thread Márton Balassi
Hi Alex, Please do share, this comes up somewhat frequently. Marton On Mon, Feb 13, 2023 at 7:44 PM Őrhidi Mátyás wrote: > Hi Alex, > > This is a reasonable request IMO. I've recently bumped into this topic > myself. This could be handy for supporting schema registries in Kafka to > Kafka scen

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.4.0, release candidate #1

2023-02-21 Thread Márton Balassi
Thank you, Gyula. +1 (binding) - Verified Helm repo works as expected, points to correct image tag, build, version - Verified basic examples + checked operator logs everything looks as expected - Verified hashes, signatures and source release contains no binaries - Ran built-in tests, built jars

Re: [DISCUSS] Apache Bahir retired

2024-02-28 Thread Márton Balassi
Hi team, Thanks for bringing this up, Feri. I am +1 for maintaining the Kudu connector as an external Flink connector. As per the legal/trademark questions this is actually fair game because one does not donate code to a specific Apache project, technically it is donated to the Apache Software fo

Re: [VOTE] FLIP-314: Support Customized Job Lineage Listener

2024-02-28 Thread Márton Balassi
+1 (binding) Marton On Wed, Feb 28, 2024 at 5:14 PM Gyula Fóra wrote: > +1 (binding) > > Gyula > > On Wed, Feb 28, 2024 at 11:10 AM Maciej Obuchowski > > wrote: > > > +1 (non-binding) > > > > Best, > > Maciej Obuchowski > > > > śr., 28 lut 2024 o 10:29 Zhanghao Chen > > napisał(a): > > > > >

Re: [DISCUSS] FLIP Suggestion: Externalize Kudu Connector from Bahir

2024-03-06 Thread Márton Balassi
Hi Feri, +1. Thanks for initiating this, the FLIP proposal looks good to me. On Wed, Mar 6, 2024 at 4:24 PM Ferenc Csaky wrote: > Hello devs, > > Opening this thread to discuss a FLIP [1] about externalizing the Kudu > connector, as recently > the Apache Bahir project were moved to the attic [2

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.8.0, release candidate #1

2024-03-21 Thread Márton Balassi
+1 (binding) As per Gyula's suggestion above verified with " ghcr.io/apache/flink-kubernetes-operator:91d67d9 ". - Verified Helm repo works as expected, points to correct image tag, build, version - Verified basic examples + checked operator logs everything looks as expected - Verified hashes, si

Re: [VOTE] FLIP-439: Externalize Kudu Connector from Bahir

2024-03-21 Thread Márton Balassi
+1(binding) On Thu, Mar 21, 2024 at 1:24 PM Leonard Xu wrote: > +1(binding) > > Best, > Leonard > > > 2024年3月21日 下午5:21,Martijn Visser 写道: > > > > +1 (binding) > > > > On Thu, Mar 21, 2024 at 8:01 AM gongzhongqiang < > gongzhongqi...@apache.org> > > wrote: > > > >> +1 (non-binding) > >> > >> Be

Re: [DISCUSS] Planning Flink 1.20

2024-03-25 Thread Márton Balassi
Thanks for kicking this off, folks. +1 for the timeline and the release manager candidates (Weijie, Rui Fan,Ufuk/Robert). On Mon, Mar 25, 2024 at 12:54 PM Leonard Xu wrote: > Wow, happy to see Ufuk and Robert join the release managers group. > > +1 for the release manager candidates(Weijie, Rui

Re: Flink Kubernetes Operator 1.9.0 release planning

2024-06-11 Thread Márton Balassi
+1 for cutting the release and Gyula as the release manager. On Tue, Jun 11, 2024 at 10:41 AM David Radley wrote: > I agree – thanks for driving this Gyula. > > From: Rui Fan <1996fan...@gmail.com> > Date: Tuesday, 11 June 2024 at 02:52 > To: dev@flink.apache.org > Cc: Mate Czagany > Subject:

Re: [VOTE] FLIP-464: Merge "flink run" and "flink run-application"

2024-06-12 Thread Márton Balassi
+1 (binding) On Wed, Jun 12, 2024 at 7:25 PM Őrhidi Mátyás wrote: > Sounds reasonable, > +1 > > Cheers, > Matyas > > > On Wed, Jun 12, 2024 at 8:54 AM Mate Czagany wrote: > > > Hi, > > > > Thank you for driving this Ferenc, > > +1 (non-binding) > > > > Regards, > > Mate > > > > Ferenc Csaky ez

Re: [VOTE] Apache Flink Kubernetes Operator Release 0.1.0, release candidate #2

2022-03-30 Thread Márton Balassi
Hi team, I would like to ask for your input in naming the operator docker image and helm chart. [1] For the sake of brevity when we started the Kubernetes Operator work we named the docker image and the helm chart simply flink-operator, while the git repository is named flink-kubernetes-operator.

Re: [VOTE] Apache Flink Kubernetes Operator Release 0.1.0, release candidate #3

2022-03-30 Thread Márton Balassi
+1 (binding) Verified the following: - shasums - gpg signatures - source does not contain any binaries - built from source - deployed via helm after adding the distribution webserver endpoint as a helm registry - all relevant files have license headers On Wed, Mar 30, 2022

Re: [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 0.1.0, release candidate #3

2022-04-02 Thread Márton Balassi
Thank you team, it was a pleasure to witness the community investing into this much requested topic and coming to an initial release so swiftly. On Sat, Apr 2, 2022 at 4:45 PM Gyula Fóra wrote: > I'm happy to announce that we have unanimously approved this release. > > There are 8 approving vote

Re: [DISCUSS] DockerHub repository maintainers

2022-05-07 Thread Márton Balassi
Hi team, I volunteer for the flink-kubernetes-operator repo. On Fri, May 6, 2022 at 1:42 PM Xintong Song wrote: > @Till, > > Thanks for volunteering. > > @Konstantin, > > From my experience, the effort that requires DockerHub access in the main > project release process is quite limited. I help

Re: Re: [ANNOUNCE] New Flink PMC member: Yang Wang

2022-05-10 Thread Márton Balassi
Congrats, Yang. Well deserved :-) On Tue, May 10, 2022 at 9:16 AM Terry Wang wrote: > Congrats Yang! > > On Mon, May 9, 2022 at 11:19 AM LuNing Wang wrote: > > > Congrats Yang! > > > > Best, > > LuNing Wang > > > > Dian Fu 于2022年5月7日周六 17:21写道: > > > > > Congrats Yang! > > > > > > Regards, > >

Re: [VOTE] Creating an Apache Flink slack workspace

2022-05-17 Thread Márton Balassi
+1 (binding) On Tue, May 17, 2022 at 11:00 AM Jingsong Li wrote: > Thank Xintong for driving this work. > > +1 > > Best, > Jingsong > > On Tue, May 17, 2022 at 4:49 PM Martijn Visser > wrote: > > > +1 (binding) > > > > On Tue, 17 May 2022 at 10:38, Yu Li wrote: > > > > > +1 (binding) > > > > >

Re: [ANNOUNCE] Kubernetes Operator release-1.0 branch cut

2022-05-17 Thread Márton Balassi
Thanks Gyula and Yang. Awesome! On Tue, May 17, 2022 at 4:46 PM Gyula Fóra wrote: > Hi Flink devs! > > The release-1.0 branch has been forked from main and version numbers have > been upgraded accordingly. > > https://github.com/apache/flink-kubernetes-operator/tree/release-1.0 > > The version o

Re: [DISCUSS] Bi-Weekly Flink Community Sync Meeting

2022-05-31 Thread Márton Balassi
Hi Robert, Thanks for the suggestion +1 from me. You already listed the topic of the timezone on the wiki that I wanted to bring up. On Tue, May 31, 2022 at 9:38 AM Robert Metzger wrote: > Hi everyone, > > We currently have a bi-weekly release sync meeting on Google Meet every > Tuesday at 9am

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.0.0, release candidate #3

2022-06-01 Thread Márton Balassi
> > Gyula > > On Wed, Jun 1, 2022 at 7:56 AM Yang Wang wrote: > >> Thanks all for your testing and patience. >> >> And sorry for I have to cancel this VOTE since @Márton Balassi >> found a license issue. We do not list the >> CSS/docs dependencies in the

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.0.0, release candidate #4

2022-06-01 Thread Márton Balassi
Hi team, +1 (binding) Verified the following: - NOTICE file looks good :-) - Signatures, Hashes - No binaries in source release - Helm Repo works, Helm install works, docker image matches release commit tag - Build from source, build container from source - Submit example application, session an

Re: [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.0.0, release candidate #4

2022-06-03 Thread Márton Balassi
Well done, team. :-) Thanks for managing the release, Yang. On Fri 3. Jun 2022 at 17:58, Yang Wang wrote: > I'm happy to announce that we have unanimously approved this release. > > There are 5 approving votes, 3 of which are binding: > > * Marton Balassi (binding) > > * Gyula Fora (binding) > >

Re: [DISCUSS] FLIP-211: Kerberos delegation token framework

2022-01-11 Thread Márton Balassi
Hi G, Thanks for taking this challenge on. Scalable Kerberos authentication support is important for Flink, delegation tokens is a great mechanism to future-proof this. I second your assessment that the existing implementation could use some improvement too and like the approach you have outlined.

Re: Flink native k8s integration vs. operator

2022-01-13 Thread Márton Balassi
Hi All, I am pleased to see the level of enthusiasm and technical consideration already emerging in this thread. I wholeheartedly support building an operator and endorsing it via placing it under the Apache Flink umbrella (as a separate repository) as the current lack of it is clearly becoming an

Re: [VOTE] FLIP-211: Kerberos delegation token framework

2022-01-31 Thread Márton Balassi
+1 (binding) Given [1] I consider the issue David raised resolved. Thanks David and please confirm here. [1] https://lists.apache.org/thread/cvwknd5fhohj0wfv8mfwn70jwpjvxrjj On Mon, Jan 24, 2022 at 11:07 AM David Morávek wrote: > Hi Gabor, > > Thanks for driving this. This is headed in a righ

Re: [DISCUSS] FLIP-212: Introduce Flink Kubernetes Operator

2022-02-01 Thread Márton Balassi
Hi team, Thank you for the great feedback, Thomas has updated the FLIP page accordingly. If you are comfortable with the currently existing design and depth in the FLIP [1] I suggest moving forward to the voting stage - once that reaches a positive conclusion it lets us create the separate code re

Re: [VOTE] FLIP-212: Introduce Flink Kubernetes Operator

2022-02-06 Thread Márton Balassi
+1 (binding) On Sat, Feb 5, 2022 at 5:35 PM Israel Ekpo wrote: > I am very excited to see this. > > Thanks for driving the effort > > +1 (non-binding) > > > On Sat, Feb 5, 2022 at 10:53 AM Shqiprim Bunjaku < > shqiprimbunj...@gmail.com> > wrote: > > > +1 (non-binding) > > > > > > > > On Sat, Feb

Re: [DISCUSS] FLIP-212: Introduce Flink Kubernetes Operator

2022-02-15 Thread Márton Balassi
gt; > > > > Thomas > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > On Fri, Feb 4, 2022 at 5:15 AM Gyula Fóra <

Re: Change of focus

2022-02-28 Thread Márton Balassi
Thank you, Till. Good luck with the next chapter. :-) On Mon, Feb 28, 2022 at 1:49 PM Flavio Pompermaier wrote: > Good luck for your new adventure Till! > > On Mon, Feb 28, 2022 at 12:00 PM Till Rohrmann > wrote: > > > Hi everyone, > > > > I wanted to let you know that I will be less active in

[DISCUSS] Dashboard/HistoryServer authentication

2021-05-31 Thread Márton Balassi
Hi team, Firstly I would like to introduce Gabor or G [1] for short to the community, he is a Spark committer who has recently transitioned to the Flink Engineering team at Cloudera and is looking forward to contributing to Apache Flink. Previously G primarily focused on Spark Streaming and securi

Re: [DISCUSS] Dashboard/HistoryServer authentication

2021-06-02 Thread Márton Balassi
ea since it makes the overall maintenance harder. > > > > Cheers, > > Till > > > > On Mon, May 31, 2021 at 4:57 PM Márton Balassi > wrote: > > > >> Hi team, > >> > >> Firstly I would like to introduce Gabor or G [1] for short to the &g

Re: [DISCUSS] Dashboard/HistoryServer authentication

2021-06-03 Thread Márton Balassi
ntication >>>> > (assuming a properly secured setup)? I mean if an attacker can get >>>> access >>>> > to one of the machines, then it should also be possible to obtain the >>>> right >>>> > Kerberos token. >>>> > &g

Re: [DISCUSS] Dashboard/HistoryServer authentication

2021-06-21 Thread Márton Balassi
the user request hits the >> proxy, >> > it >> > >>> >> should no >> > >>> >> >>>> longer be under his control. I think I do not fully >> understand >> > >>> yet >> > >>> >> why this >> > >>> >&g

Re: [DISCUSS] Dashboard/HistoryServer authentication

2021-06-22 Thread Márton Balassi
Flink > more compatible with the modern solutions to this problem. > > Best, > Austin > > On Mon, Jun 21, 2021 at 2:18 PM Márton Balassi > wrote: > > > Hi team, > > > > Thank you for your input. Based on this discussion I agree with G that > > selecting

Re: [DISCUSS] Dashboard/HistoryServer authentication

2021-06-29 Thread Márton Balassi
ource frameworks (CNCF > mostly). > > I > > > am sure you agree that it is important for Apache Flink to stay open > and > > to > > > consider different approaches and ideas and I don't think it helps the > > > culture of discussion to shoot it down like t

Re: [DISCUSS] Dashboard/HistoryServer authentication

2021-07-05 Thread Márton Balassi
ble as Netty API. Since there is > >>> guarantee on no breaking changes between minor versions we can give the > >>> same guarantee. > >>> If for whatever reason we need to break it we can do it in major > version > >>> like every o

[VOTE] FLIP-181: Custom netty HTTP request inbound/outbound handlers

2021-07-06 Thread Márton Balassi
Hi everyone, I would like to start a vote on FLIP-181 [1] which was discussed in this thread [2]. The vote will be open for at least 72 hours until July 9th unless there is an objection or not enough votes. [1] https://cwiki.apache.org/confluence/x/CAUBCw [2] https://lists.apache.org/thread.html/r

Re: [VOTE] FLIP-181: Custom netty HTTP request inbound/outbound handlers

2021-07-10 Thread Márton Balassi
d addition that will open many possibilities in the future > > and > > > solve some immediate issues with the current Kerberos integration. > > > > > > Gyula > > > > > > On Tue, Jul 6, 2021 at 2:50 PM Márton Balassi < > balassi.mar...@gmail.co

Re: Introduction email

2021-07-19 Thread Márton Balassi
Hi Srini, Welcome to the community. Awesome to hear that LinkedIn decided to embrace Flink, excited to see where this joint path leads us. On Mon, Jul 19, 2021 at 11:02 AM Timo Walther wrote: > Hi Srini, > > welcome aboard! Great to see more adoption in the SQL space. Looking > forward to colla

Re: [VOTE] FLIP-181: Custom netty HTTP request inbound/outbound handlers

2021-07-22 Thread Márton Balassi
>> >> > The vote has not reached the required number of votes to be considered >> > successful. >> > >> > As outlined in the bylaws >> > < >> > >> https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=120731026#FlinkByla

Re: Looking for Maintainers for Flink on YARN

2021-07-29 Thread Márton Balassi
Hi Konstantin, Thank you for raising this topic, our development team at Cloudera would be happy to step up to address this responsibility. Best, Marton On Thu, Jul 29, 2021 at 10:15 AM Konstantin Knauf wrote: > Dear community, > > We are looking for community members, who would like to mainta

Re: [DISCUSS] Flink Kubernetes Operator release cadence proposal

2022-06-22 Thread Márton Balassi
Thanks for the proposal, Matyas. +1 for 2 month release cycles with the breakdown Gyula suggested. @Yang: we could start tagging features with 1.1 / 1.2 version then, good call. On Wed, Jun 22, 2022 at 4:58 AM Yang Wang wrote: > +1 for 2 month release cycles. > > Since we have promised the bac

Re: [DISCUSS] Release Kubernetes operator 1.0.1

2022-06-22 Thread Márton Balassi
Hi team, +1 for having a 1.0.1 for the Kubernetes Operator. On Wed, Jun 22, 2022 at 4:23 PM Gyula Fóra wrote: > Hi Devs! > > How do you feel about releasing the 1.0.1 patch release for the Kubernetes > operator? > > We have fixed a few annoying issues that many people tend to hit. > > Given tha

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.0.1, release candidate #1

2022-06-27 Thread Márton Balassi
+1 (binding) Successfully verified the following: - Verify that the checksums and GPG files - Verify that the source distributions do not contain any binaries - Build binary and image from release source - Verify the NOTICE and licenses in source release and the docker image - Operator functionali

Re: [VOTE] Creating benchmark channel in Apache Flink slack

2022-07-11 Thread Márton Balassi
+1 (binding). Thanks! I can help you with the Slack admin steps if needed. On Mon, Jul 11, 2022 at 10:55 AM godfrey he wrote: > +1, Thanks for driving this! > > Best, > Godfrey > > Yuan Mei 于2022年7月11日周一 16:13写道: > > > > +1 (binding) & thanks for the efforts! > > > > Best > > Yuan > > > > > >

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.1.0, release candidate #1

2022-07-22 Thread Márton Balassi
+1 (binding) Successfully verified the following: - Checksums and gpg signatures - No binaries in source release - Build from source, build image from source - Helm Repo works, Helm install works - Notice files look good - Upgraded a cluster from 1.0.0 and run some examples Specifically for FLINK

Re: [VOTE] FLIP-250: Support Customized Kubernetes Schedulers Proposal

2022-07-28 Thread Márton Balassi
+1 (binding) On Wed, Jul 27, 2022 at 8:22 PM Gyula Fóra wrote: > +1 (binding) > > Gyula > > On Wed, 27 Jul 2022 at 03:52, MrL wrote: > > > +1 (non-binding) > > > > > 2022年7月27日 09:18,William Wang 写道: > > > > > > +1 (non-binding) > > > > > > bo zhaobo 于2022年7月25日周一 09:38写道: > > > > > >> Hi all

Re: [DISCUSS] Stale PR action for flink and flink-kubernetes-operator repos

2022-09-14 Thread Márton Balassi
Hi gents, Thanks for the stats Martjin, that valuable insight into the situation. Having a large number of open, stale PRs can also result in a bad contributor experience down the line, as in my opinion it can reach a point where it discourages committers reviewing them as it starts to feel like a

Re: Kubernetes Operator 1.2.0 release

2022-09-20 Thread Márton Balassi
Thanks, +1 for the schedule. On Tue, Sep 20, 2022 at 6:20 AM Yang Wang wrote: > Thanks Gyula for managing the release. > > +1 for the time schedule. > > > Best, > Yang > > > > Őrhidi Mátyás 于2022年9月19日周一 22:28写道: > > > Thanks Gyula! > > > > Sounds good! Happy to help as always. > > > > Cheers,

Re: [DISCUSS] FLIP-265 Deprecate and remove Scala API support

2022-10-03 Thread Márton Balassi
Hi Martjin, Thanks for compiling the FLIP. I agree with the sentiment that Scala poses considerable maintenance overhead and key improvements (like 2.13 or 2.12.8 supports) are hanging stale. With that said before we make this move we should attempt to understand the userbase affected. A quick Sla

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.2.0, release candidate #2

2022-10-06 Thread Márton Balassi
+1 (binding) Verified upgrade process from 1.1 with a running application On Thu, Oct 6, 2022 at 5:52 PM Biao Geng wrote: > +1(non-binding) > Thanks a lot for the great work. > > Successfully verified the following: > - Checksums and gpg signatures of the tar files. > - No binaries in source re

Re: [Discuss]- Donate Iceberg Flink Connector

2022-10-10 Thread Márton Balassi
Hi Abid, Just to clarify does your suggestion mean that the Iceberg community would like to remove the iceberg-flink connector from the Iceberg codebase and maintain it under Flink instead? A new separate repo under the Flink project umbrella given the current existing effort to extract connectors

Re: Re: Re: [Discuss]- Donate Iceberg Flink Connector

2022-10-12 Thread Márton Balassi
> > Iceberg > > > > repo into a separate repo under the Flink umbrella. > > > > > > > > Sorry about the doc permissions! I was able to create a FLIP-267: > > > > > > > https://cwiki.apache.org/confluence/display/FLINK/FLIP+267%3A+I

Re: [DISCUSS] FLIP-265 Deprecate and remove Scala API support

2022-10-13 Thread Márton Balassi
k but forgot to do so. I'll do some >>> more outreach via other channels as well. >>> >>> @Users of Flink, I've made a proposal to deprecate and remove Scala API >>> support in a future version of Flink. Your feedback on this topic is very >>>

Re: [DISCUSS] Changing the minimal supported version of Hadoop to 2.10.2

2022-10-17 Thread Márton Balassi
Hi Martjin, +1 for 2.10.2. Do you expect to have bandwidth in the near term to implement the bump? On Wed, Oct 5, 2022 at 5:00 PM Gabor Somogyi wrote: > Hi Martin, > > Thanks for bringing this up! Lately I was thinking about to bump the hadoop > version to at least 2.6.1 to clean up issues like

Re: [VOTE] FLIP-265 Deprecate and remove Scala API support

2022-10-17 Thread Márton Balassi
+1 (binding) On Mon, Oct 17, 2022 at 3:39 PM Martijn Visser wrote: > Hi everyone, > > I'm hereby opening a vote for FLIP-265 Deprecate and remove Scala API > support. The related discussion can be found here [1]. > > Voting will be open for at least 72 hours. > > Best regards, > > Martijn > http

Re: [ANNOUNCE] Apache Flink 1.16.0 released

2022-10-28 Thread Márton Balassi
Awesome, thanks team! Thanks Xingbo for managing the release. On Fri, Oct 28, 2022 at 11:04 AM Biao Liu wrote: > Congrats! Glad to hear that. > > BTW, I just found the document link of 1.16 from https://flink.apache.org/ > is not correct. > > [image: 截屏2022-10-28 17.01.28.png] > > Thanks, > Biao

Re: [DISCUSS] FLIP-271: Autoscaling

2022-11-05 Thread Márton Balassi
Thanks for preparing the FLIP and kicking off the discussion, Max. Looking forward to this. :-) On Sat, Nov 5, 2022 at 9:27 AM Niels Basjes wrote: > I'm really looking forward to seeing this in action. > > Niels > > On Fri, 4 Nov 2022, 19:37 Maximilian Michels, wrote: > >> Hi, >> >> I would lik

Re: [DISCUSS] Issue tracking workflow

2022-11-12 Thread Márton Balassi
Hi Martjin, Given the situation let us set up the Jira signup mailing list following the Calcite model. This seems the most sensible to me as of now. On Fri, Nov 11, 2022 at 7:26 PM Martijn Visser wrote: > Hi everyone, > > Unfortunately ASF Infra has already implemented the change and new Jira

Re: [VOTE] FLIP-272: Generalized delegation token support

2022-11-18 Thread Márton Balassi
+1 (binding) On Thu, Nov 17, 2022 at 9:06 AM Gabor Somogyi wrote: > Hi All, > > I'm hereby opening a vote for FLIP-272 Generalized delegation token > support. > The related documents can be found here: > - FLIP on wiki: [1] > - Discussion thread: [2] > > Voting will be open for at least 72 hours

[ANNOUNCE] New Apache Flink Committer - Matyas Orhidi

2022-11-21 Thread Márton Balassi
Hi everyone, On behalf of the PMC, I'm very happy to announce Matyas Orhidi as a new Flink committer. Matyas has over a decade of experience of the Big Data ecosystem and has been working with Flink full time for the past 3 years. In the open source community he is one of the key driving members

Re: [DISCUSS] FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API)

2020-07-30 Thread Márton Balassi
Hi All, Thanks for the write up and starting the discussion. I am in favor of unifying the APIs the way described in the FLIP and deprecating the DataSet API. I am looking forward to the detailed discussion of the changes necessary. Best, Marton On Wed, Jul 29, 2020 at 12:46 PM Aljoscha Krettek

Re: [DISCUSS] Upgrade HBase connector to 2.2.x

2020-08-07 Thread Márton Balassi
Hi Robert and Gyula, Thanks for reviving this thread. We have the implementation (currently for 2.2.3) and it is straightforward to contribute it back. Miklos (ccd) has recently written a readme for said version, he would be interested in contributing the upgraded connector back. The latest HBase

Re: [DISCUSS] Upgrade HBase connector to 2.2.x

2020-08-10 Thread Márton Balassi
;> connector and other connectors. >> >> Best, >> Jark >> >> >> On Fri, 7 Aug 2020 at 17:54, Robert Metzger wrote: >> >>> Hi, >>> >>> Thank you for picking this up so quickly. I have no objections regarding >>> all the pro

Re: [DISCUSS] Dropping Scala 2.10

2017-09-19 Thread Márton Balassi
Hi Aljoscha, I am in favor of the change. No concerns on my side, just one remark that I have talked to Sean last week (ccd) and he mentioned that he has faced some technical issues while driving the transition from 2.10 to 2.12 for Spark. It had to do with changes in the scope of implicits. You m

Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata

2024-08-08 Thread Márton Balassi
Hi team, Thank you for the proposal, Gabor and the review, Zakelly. Let me provide more context on the intended outcome, let us agree on the desirability of that first and then we can come back to the technical details. The pain point that we observed with multiple users is that their operations

Re: [VOTE] FLIP-474: Store operator name and UID in state metadata

2024-08-26 Thread Márton Balassi
+1 (binding) Thanks for clarifying the big picture [1], that helps a lot. [1] https://docs.google.com/document/d/1Du1-TShoOjaNDCahs3sgLWIpYkXzJPdSkgHcWLpELyw/edit?usp=sharing On Mon, Aug 26, 2024 at 10:02 AM Gabor Somogyi wrote: > Hi All, > > I would like to start a vote on FLIP-474: Store ope

Re: 2.0 podcast

2024-10-07 Thread Márton Balassi
Hi Rich, Thanks for reaching out, that is a great idea. Unfortunately I am not aware of Flink folks that are joining the Denver conference this year. Best, Marton On Thu, Oct 3, 2024 at 9:39 PM Rich Bowen wrote: > Hi, folks, > > I understand you have 2.0 coming up pretty soon. I was wondering

Re: [DISCUSS] Release HBase connector with partial JDK support

2024-10-22 Thread Márton Balassi
Hi Feri, Thanks for carefully considering this situation. I agree with your proposal that it is best to provide an HBase connector release with partial JDK support for the time being, and list the limitations in the Java compatibility docs. On a partially related note this highlights that the com

Re: [DISCUSS] Release HBase connector with partial JDK support

2024-10-29 Thread Márton Balassi
+1 for Ferenc as the release manager and the content. On Mon, Oct 28, 2024 at 5:03 PM Ferenc Csaky wrote: > Hi, > > Based on this discussion I would like to suggest to move on with > the originally planned release with the HBase connector 4.0, that > will support 1.18, and 1.19. > > I volunteer

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1

2024-10-23 Thread Márton Balassi
+1 (binding) - Verified Helm repo works as expected, points to correct image tag, build, version - Verified basic examples + checked operator logs everything looks as expected - Verified hashes, signatures and source release contains no binaries - Ran built-in tests, built jars + docker image from

Re: [VOTE] Release flink-connector-hbase v4.0.0, release candidate #1

2024-11-15 Thread Márton Balassi
+1 (binding) - Verified JIRA release notes - Built from source with JDK 11 - Verified checksum and signatures - Verified source code does not contain binaries - Verified artifacts deployed to the maven repository - Verified no binaries in source release Thanks, Feri. Cheers, Marton On Thu, Nov

Re: [VOTE] Release 1.19.2, release candidate #1

2025-02-11 Thread Márton Balassi
+1 (binding) 1. Verified the archives, checksums, and signatures 2. Extracted and inspected the source code for binaries 3. Built the source code 4. Verified license files / headers Best, Marton On Mon, Feb 3, 2025 at 12:37 PM Maximilian Michels wrote: > +1 (binding) > > 1. Verified the archiv

Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases)

2025-01-22 Thread Márton Balassi
+1 for option (2) Marton On Wed, Jan 22, 2025 at 2:10 PM Maximilian Michels wrote: > +1 for option (2), looks like the best compromise given the constraints. > > -Max > > On Tue, Jan 21, 2025 at 2:27 PM Ferenc Csaky > wrote: > > > > FYI, I opened a PR about documenting the fine-tuning options

Re: [VOTE] FLIP-496: SQL connector for keyed state data

2025-01-10 Thread Márton Balassi
+1 (binding) Thanks, G. On Thu, Jan 9, 2025 at 4:17 PM Zakelly Lan wrote: > +1 (binding) > > Thanks for driving this. > > Best, > Zakelly > > On Thu, Jan 9, 2025 at 8:57 PM Gabor Somogyi > wrote: > > > Hi All, > > > > I'd like to start a vote of FLIP-496: SQL connector for keyed state data > >

Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic)

2025-03-21 Thread Márton Balassi
+1 (binding) On Thu, Mar 20, 2025 at 4:53 PM Pedro Mázala wrote: > One question. > > When we say > > > > >- Records/data will be duplicated for as long as both pipelines are > >running concurrently > > > > > Do we mean the source record will be forwarded to both pipelines? I'm > asking t

Re: [DISCUSS] Release externalized Kudu connector

2025-03-27 Thread Márton Balassi
Hi Ferenc, +1. It makes sense to move the Kudu connector under the Flink umbrella, I agree that it should support Flink 1.19 and 1.20 (maybe 2.0 soon) and thanks for volunteering as the release manager. Cheers, Marton On Fri, Mar 21, 2025 at 1:00 PM Ferenc Csaky wrote: > Hello devs, > > I woul

Re: [VOTE] Release flink-connector-kudu v2.0.0, release candidate #1

2025-04-09 Thread Márton Balassi
Thanks. +1 (binding) Verified: - Checkpoints, signatures - Checked notice files + no binaries in source release - Built from source - Verified release tag, release notes and website PR Best, Marton On Wed, Apr 9, 2025 at 9:19 AM Yanquan Lv wrote: > +1 (non-binding) > > I checked: > - Revi

Re: [VOTE] FLIP-522: Add generalized type information to SQL state connector

2025-04-21 Thread Márton Balassi
+1 (binding) On Mon, Apr 21, 2025 at 9:27 AM Gabor Somogyi wrote: > Hi All, > > I'd like to start a vote on FLIP-522: Add generalized type information to > SQL state connector [1] > which has been discussed in this thread [2]. > > The vote will be open for at least 72 hours unless there is an ob

Re: [VOTE] Release 1.20.2, release candidate #2

2025-06-22 Thread Márton Balassi
+1 (binding) - Checked release notes - Verified checksums and signatures - Verified that no binaries can be found in the source archives - Verified build using Maven 3.8.6 and (Apple) JDK 17 - Verified flink-web PR Marton On Thu, Jun 19, 2025 at 5:47 PM Mate Czagany wrote: > Hi Ferenc, > > Tha

Re: [VOTE] Release 1.19.3, release candidate #2

2025-06-22 Thread Márton Balassi
+1 (binding) - Checked release notes - Verified checksums and signatures - Verified that no binaries can be found in the source archives - Verified build using Maven 3.8.6 and (Apple) JDK 17 - Verified flink-web PR Marton On Thu, Jun 19, 2025 at 7:28 PM Mate Czagany wrote: > Hi, > > +1 (non-bi

<    1   2   3