Re: [ANNOUNCE] Apache Flink 1.9.0 released

It is great news for the community. Thanks to everyone who contributed to the release management. Congratulations! On Thu, Aug 22, 2019 at 9:14 PM Haibo Sun wrote: > Great news! Thanks Gordon and Kurt! > > Best, > Haibo > > > At 2019-08-22 20:03:26, "Tzu-Li (Gordon) Tai" wrote: > >The Apache

Re:[ANNOUNCE] Apache Flink 1.9.0 released

Great news! Thanks Gordon and Kurt!Best, Haibo At 2019-08-22 20:03:26, "Tzu-Li (Gordon) Tai" wrote: >The Apache Flink community is very happy to announce the release of Apache >Flink 1.9.0, which is the latest major release. > >Apache Flink® is an open-source stream processing framework for

Re: [DISCUSS] Flink Python User-Defined Function for Table API

+1 for starting the vote. Thanks Jincheng a lot for the discussion. Best, Hequn On Fri, Aug 23, 2019 at 10:06 AM Dian Fu wrote: > Hi Jincheng, > > +1 to start the FLIP create and VOTE on this feature. I'm willing to help > on the FLIP create if you don't mind. As I haven't created a FLIP

Re: [DISCUSS] Flink client api enhancement for downstream project

Hi Yang, It would be helpful if you check Stephan's last comment, which states that isolation is important. For per-job mode, we run a dedicated cluster(maybe it should have been a couple of JM and TMs during FLIP-6 design) for a specific job. Thus the process is prevented from other jobs. In

Re: [ANNOUNCE] Apache Flink 1.9.0 released

Great news! Thanks Gordon and Kurt for pushing this forward and everybody who contributed to this release. Regards, Dian > 在 2019年8月23日，上午9:41，Guowei Ma 写道： > > Congratulations!! > Best, > Guowei > > > Congxian Qiu mailto:qcx978132...@gmail.com>> > 于2019年8月23日周五 上午9:32写道： >

Re: [DISCUSS] Flink Python User-Defined Function for Table API

Hi Jincheng, +1 to start the FLIP create and VOTE on this feature. I'm willing to help on the FLIP create if you don't mind. As I haven't created a FLIP before, it will be great if you could help on this. :) Regards, Dian > 在 2019年8月22日，下午11:41，jincheng sun 写道： > > Hi all, > > Thanks a lot

Re: CiBot Update

Thanks Chesnay for your great work! A very useful feature! Just one minor suggestion: It will be better if we could add this command to the section "Bot commands" in the flinkbot template. Regards, Dian > 在 2019年8月23日，上午2:06，Ethan Li 写道： > > My question is specifically about implementation

Re: CiBot Update

My question is specifically about implementation of "@flinkbot run travis" > On Aug 22, 2019, at 1:06 PM, Ethan Li wrote: > > Hi Chesnay, > > This is really nice feature! > > Can I ask how is this implemented? Do you have the related Jira/PR/docs that > I can take a look? I’d like to

Re: CiBot Update

Hi Chesnay, This is really nice feature! Can I ask how is this implemented? Do you have the related Jira/PR/docs that I can take a look? I’d like to introduce it to another project if applicable. Thank you very much! Best, Ethan > On Aug 22, 2019, at 8:34 AM, Biao Liu wrote: > > Thanks

Re: [DISCUSS] Flink project bylaws

Thanks for collecting the ideas of Bylaws changes. It is a good idea! Jiangjie (Becket) Qin On Thu, Aug 22, 2019 at 12:11 PM Robert Metzger wrote: > I have started a Wiki page (editable by all) for collecting ideas for > Bylaws changes, so that we can batch changes together and then vote on >

Re: [DISCUSS] Flink Python User-Defined Function for Table API

Hi all, Thanks a lot for your feedback. If there are no more suggestions and comments, I think it's better to initiate a vote to create a FLIP for Apache Flink Python UDFs. What do you think? Best, Jincheng jincheng sun 于2019年8月15日周四 上午12:54写道： > Hi Thomas, > > Thanks for your confirmation

Re: [VOTE] Flink Project Bylaws

+1 Becket Qin 于2019年8月22日 周四16:22写道： > Hi All, so far the votes count as following: > > +1 (Binding): 13 (Aljoscha, Fabian, Kurt, Till, Timo, Max, Stephan, > Gordon, Robert, Ufuk, Chesnay, Shaoxuan, Henry) > +0 (Binding): 1 (Thomas) > > +1 (Non-Binding): 10 (Hequn, Vino, Piotr, Dawid, Xintong,

[jira] [Created] (FLINK-13822) TableAggregateITCase.testGroupByFlatAggregate test failure: IllegalStateException: Concurrent access to KryoSerializer.

Alex created FLINK-13822: Summary: TableAggregateITCase.testGroupByFlatAggregate test failure: IllegalStateException: Concurrent access to KryoSerializer. Key: FLINK-13822 URL:

Re: [DISCUSS][CODE STYLE] Breaking long function argument lists and chained method calls

FYI PR: https://github.com/apache/flink-web/pull/254 On Thu, Aug 22, 2019 at 10:11 AM Andrey Zagrebin wrote: > Hi Tison, > > Regarding the automatic checks. > Yes, I suggest we conclude the discussion without the automatic checks. > As soon as we have more ideas/investigation, put into

[jira] [Created] (FLINK-13821) Website must link to License etc

Sebb created FLINK-13821: Summary: Website must link to License etc Key: FLINK-13821 URL: https://issues.apache.org/jira/browse/FLINK-13821 Project: Flink Issue Type: Bug Reporter: Sebb

[jira] [Created] (FLINK-13820) Breaking long function argument lists and chained method calls

Andrey Zagrebin created FLINK-13820: --- Summary: Breaking long function argument lists and chained method calls Key: FLINK-13820 URL: https://issues.apache.org/jira/browse/FLINK-13820 Project: Flink

Re: CiBot Update

Thanks Chesnay a lot, I love this feature! Thanks, Biao /'bɪ.aʊ/ On Thu, 22 Aug 2019 at 20:55, Hequn Cheng wrote: > Cool, thanks Chesnay a lot for the improvement! > > Best, Hequn > > On Thu, Aug 22, 2019 at 5:02 PM Zhu Zhu wrote: > > > Thanks Chesnay for the CI improvement! > > It is very

Re: CiBot Update

Cool, thanks Chesnay a lot for the improvement! Best, Hequn On Thu, Aug 22, 2019 at 5:02 PM Zhu Zhu wrote: > Thanks Chesnay for the CI improvement! > It is very helpful. > > Thanks, > Zhu Zhu > > zhijiang 于2019年8月22日周四 下午4:18写道： > > > It is really very convenient now. Valuable work, Chesnay!

Re: [DISCUSS] FLIP-49: Unified Memory Configuration for TaskExecutors

Hi everyone, I just updated the FLIP document on wiki [1], with the following changes. - Removed open question regarding MemorySegment allocation. As discussed, we exclude this topic from the scope of this FLIP. - Updated content about JVM direct memory parameter according to recent

[DISCUSS] Enhance Support for Multicast Communication Pattern

Hi everyone, In some scenarios we met a requirement that some operators want to send records to theirs downstream operators with an multicast communication pattern. In detail, for some records, the operators want to send them according to the partitioner (for example, Rebalance), and for

Re: [ANNOUNCE] Apache Flink 1.9.0 released

Great news! Thanks a lot to everyone who helped making this release possible and in particular to our release managers Gordon and Kurt for the hard work. Cheers, Till On Thu, Aug 22, 2019 at 2:22 PM Timo Walther wrote: > Thanks to everyone who contributed to this release. Great team work! > >

Re: [ANNOUNCE] Apache Flink 1.9.0 released

Thanks to everyone who contributed to this release. Great team work! Regards, Timo Am 22.08.19 um 14:16 schrieb JingsongLee: Congratulations~~~ Thanks gordon and everyone~ Best, Jingsong Lee -- From:Oytun Tez Send

Re: [DISCUSS] FLIP-54: Evolve ConfigOption and Configuration

Hi everyone, thanks for all the feedback we have received online and offline. It showed that many people support the idea of evolving the Flink configuration functionality. I'm almost sure that this FLIP will not solve all issues but at least will improve the current status. We've updated

Re: [ANNOUNCE] Apache Flink 1.9.0 released

Congratulations~~~ Thanks gordon and everyone~ Best, Jingsong Lee -- From:Oytun Tez Send Time:2019年8月22日(星期四) 14:06 To:Tzu-Li (Gordon) Tai Cc:dev ; user ; announce Subject:Re: [ANNOUNCE] Apache Flink 1.9.0 released

Re: [ANNOUNCE] Apache Flink 1.9.0 released

Congratulations! Thanks Gordon and Kurt for being the release manager. Thanks all the contributors who have made this release possible. Best, tison. Jark Wu 于2019年8月22日周四 下午8:11写道： > Congratulations! > > Thanks Gordon and Kurt for being the release manager and thanks a lot to > all the

[NOTICE] GitHub service interruption

Hello, GitHub is currently experiencing problems ; so far the one issue we saw ourselves is that Travis builds aren't triggered if a commit is pushed. This affects builds both for branches and pull requests; cron jobs may be fine. @Committers: Please keep this

Re: [ANNOUNCE] Apache Flink 1.9.0 released

Congratulations! Thanks Gordon and Kurt for being the release manager and thanks a lot to all the contributors. Cheers, Jark On Thu, 22 Aug 2019 at 20:06, Oytun Tez wrote: > Congratulations team; thanks for the update, Gordon. > > --- > Oytun Tez > > *M O T A W O R D* > The World's Fastest

[ANNOUNCE] Apache Flink 1.9.0 released

The Apache Flink community is very happy to announce the release of Apache Flink 1.9.0, which is the latest major release. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming applications. The release is

[jira] [Created] (FLINK-13819) Introduce RpcEndpoint State

Andrey Zagrebin created FLINK-13819: --- Summary: Introduce RpcEndpoint State Key: FLINK-13819 URL: https://issues.apache.org/jira/browse/FLINK-13819 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Flink project bylaws

I have started a Wiki page (editable by all) for collecting ideas for Bylaws changes, so that we can batch changes together and then vote on them: https://cwiki.apache.org/confluence/display/FLINK/Ideas+for+Bylaw+changes On Tue, Aug 13, 2019 at 1:41 PM Becket Qin wrote: > Hi Robert, > > Thanks

[jira] [Created] (FLINK-13818) Check whether web submission are enabled

Chesnay Schepler created FLINK-13818: Summary: Check whether web submission are enabled Key: FLINK-13818 URL: https://issues.apache.org/jira/browse/FLINK-13818 Project: Flink Issue Type:

[jira] [Created] (FLINK-13817) Expose whether web submissions are enabled

Chesnay Schepler created FLINK-13817: Summary: Expose whether web submissions are enabled Key: FLINK-13817 URL: https://issues.apache.org/jira/browse/FLINK-13817 Project: Flink Issue

Re: CiBot Update

Thanks Chesnay for the CI improvement! It is very helpful. Thanks, Zhu Zhu zhijiang 于2019年8月22日周四 下午4:18写道： > It is really very convenient now. Valuable work, Chesnay! > > Best, > Zhijiang > -- > From:Till Rohrmann > Send

[jira] [Created] (FLINK-13816) Long job names result in a very ugly table listing the completed jobs in the web UI

David Anderson created FLINK-13816: -- Summary: Long job names result in a very ugly table listing the completed jobs in the web UI Key: FLINK-13816 URL: https://issues.apache.org/jira/browse/FLINK-13816

[jira] [Created] (FLINK-13815) Implement the SpaceAllocator

Yu Li created FLINK-13815: - Summary: Implement the SpaceAllocator Key: FLINK-13815 URL: https://issues.apache.org/jira/browse/FLINK-13815 Project: Flink Issue Type: Sub-task Components:

Re: [VOTE] Flink Project Bylaws

Hi All, so far the votes count as following: +1 (Binding): 13 (Aljoscha, Fabian, Kurt, Till, Timo, Max, Stephan, Gordon, Robert, Ufuk, Chesnay, Shaoxuan, Henry) +0 (Binding): 1 (Thomas) +1 (Non-Binding): 10 (Hequn, Vino, Piotr, Dawid, Xintong, Yu, Jingsong, Yun, Jark, Biao) Given that more than

Re: CiBot Update

It is really very convenient now. Valuable work, Chesnay! Best, Zhijiang -- From:Till Rohrmann Send Time:2019年8月22日(星期四) 10:13 To:dev Subject:Re: CiBot Update Thanks for the continuous work on the CiBot Chesnay! Cheers, Till On

Re: CiBot Update

Thanks for the continuous work on the CiBot Chesnay! Cheers, Till On Thu, Aug 22, 2019 at 9:47 AM Jark Wu wrote: > Great work! Thanks Chesnay! > > > > On Thu, 22 Aug 2019 at 15:42, Xintong Song wrote: > > > The re-triggering travis feature is so convenient. Thanks Chesnay~! > > > > Thank you~

Re: [DISCUSS][CODE STYLE] Breaking long function argument lists and chained method calls

Hi Tison, Regarding the automatic checks. Yes, I suggest we conclude the discussion without the automatic checks. As soon as we have more ideas/investigation, put into automation, we can activate it and/or reconsider. Nonetheless, I do not see any problem if we agree on this atm and make it part

Re: [RESULT] [VOTE] Apache Flink 1.9.0, release candidate #3

@Chesnay No. Users will have to manually build and install PyFlink themselves in 1.9.0: https://ci.apache.org/projects/flink/flink-docs-release-1.9/flinkDev/building.html#build-pyflink This is also mentioned in the announcement blog post (to-be-merged):

Re: [RESULT] [VOTE] Apache Flink 1.9.0, release candidate #3

Are we also releasing python artifacts for 1.9? On 21/08/2019 19:23, Tzu-Li (Gordon) Tai wrote: I'm happy to announce that we have unanimously approved this candidate as the 1.9.0 release. There are 12 approving votes, 5 of which are binding: - Yu Li - Zili Chen - Gordon Tai - Stephan Ewen -

Re: CiBot Update

Great work! Thanks Chesnay! On Thu, 22 Aug 2019 at 15:42, Xintong Song wrote: > The re-triggering travis feature is so convenient. Thanks Chesnay~! > > Thank you~ > > Xintong Song > > > > On Thu, Aug 22, 2019 at 9:26 AM Stephan Ewen wrote: > > > Nice, thanks! > > > > On Thu, Aug 22, 2019 at

Re: CiBot Update

The re-triggering travis feature is so convenient. Thanks Chesnay~! Thank you~ Xintong Song On Thu, Aug 22, 2019 at 9:26 AM Stephan Ewen wrote: > Nice, thanks! > > On Thu, Aug 22, 2019 at 3:59 AM Zili Chen wrote: > > > Thanks for your announcement. Nice work! > > > > Best, > > tison. > > >

Re: [DISCUSS] Release flink-shaded 8.0

+1 to go ahead at some point we may want to bump the Hadoop versions for which we build the shaded jars, but that would be a another dedicated effort On Wed, Aug 21, 2019 at 1:41 PM Chesnay Schepler wrote: > Nico has opened a PR for bumping netty; we plan to have this merged by > tomorrow. > >

Re: CiBot Update

Nice, thanks! On Thu, Aug 22, 2019 at 3:59 AM Zili Chen wrote: > Thanks for your announcement. Nice work! > > Best, > tison. > > > vino yang 于2019年8月22日周四 上午8:14写道： > > > +1 for "@flinkbot run travis", it is very convenient. > > > > Chesnay Schepler 于2019年8月21日周三 下午9:12写道： > > > > > Hi

Re: [DISCUSS][CODE STYLE] Breaking long function argument lists and chained method calls

One more question, what do you differ *public **void func(* *int arg1,* *int arg2,* *...)** throws E1, E2, E3 {* *...* *}* and *public **void func(* *int arg1,* *int arg2,* *... *)** throws E1, E2, E3 {* *...* *}* I prefer the latter

Re: [VOTE] Flink Project Bylaws

Oh yeah, +1 LGTM Thanks for working on this. - Henry On Tue, Aug 20, 2019 at 2:17 AM Becket Qin wrote: > Thanks for sharing your thoughts, Thomas, Henry and Stephan. I also think > the committers are supposed to be mature enough to know when a review on > their own patch is needed. > >