Re: [ANNOUNCE] New Committers and PMC member

Congratulations! Best, Guowei Dawid Wysakowicz 于2020年4月7日周二 下午2:50写道： > Thank you all for the support! > > Best, > > Dawid > > On 02/04/2020 04:33, godfrey he wrote: > > Congratulations to all of you~ > > > > Best, > > Godfrey > > > > Ismaël Mejía 于2020年4月2日周四 上午6:42写道： > > > >> Congrats

Re: [DISCUSS] FLIP-71 - E2E View support in Flink SQL

@Danny Chan you‘re right. I have updated the doc. *Best Regards,* *Zhenghua Gao* On Wed, Apr 8, 2020 at 1:20 PM Danny Chan wrote: > +1 for the proposal, a small concern for drop view statement: > > dropViewStatement: > DROP VIEW name [ IF EXISTS ] > I think the drop statement should

Re: [DISCUSS] FLIP-71 - E2E View support in Flink SQL

This FLIP seems to be quite straightforward, +1 from my side. Best, Kurt On Tue, Apr 7, 2020 at 8:42 PM Zhenghua Gao wrote: > forward the reply to ML too. > > > *Best Regards,* > *Zhenghua Gao* > > > -- Forwarded message - > From: Zhenghua Gao > Date: Tue, Apr 7, 2020 at 8:40

Re: [VOTE] FLIP-108: Add GPU support in Flink

Hi, there I have updated the FLIP, mainly target to make it more detailed and clear. The general design is not changed, but there are still some changes need to be notified here: - Change the `ExternalResourceDriver` from abstract class to interface, since it does not have an abstract

Re: [DISCUSS]FLIP-113: Support SQL and planner hints

+1, LGTM Best, Kurt On Wed, Apr 8, 2020 at 10:27 AM Jark Wu wrote: > Thanks for the summary Danny. +1 to the new proposal. > > I have a minor concern about the global configuration > `table.optimizer.dynamic-table-options.enabled`, does it belong to > optimizer? > From my point of view, it is

[jira] [Created] (FLINK-17043) Putting more information into accounting when failing a job in FailureManager

Congxian Qiu(klion26) created FLINK-17043: - Summary: Putting more information into accounting when failing a job in FailureManager Key: FLINK-17043 URL: https://issues.apache.org/jira/browse/FLINK-17043

Re: [DISCUSS] FLIP-111: Docker image unification

Hi, all, Thanks for the reply, Andrey! I have filed two new tickets tracking the problems: 1. FLINK-17033 for upgrading base Java Docker image, I pointed out some other problems the openjdk:8-jre-alpine could have in the ticket‘s

Re: [DISCUSS]FLIP-113: Support SQL and planner hints

Thanks for the summary Danny. +1 to the new proposal. I have a minor concern about the global configuration `table.optimizer.dynamic-table-options.enabled`, does it belong to optimizer? >From my point of view, it is just an API to set table options and uses Calcite in the implementation. I'm also

Re: [VOTE] FLIP-111: Docker image unification

Thanks for the FLIP Andrey. +1 (non-binding) from my side. Regards, Canbin Zheng Yang Wang 于2020年4月8日周三 上午9:57写道： > Thanks Andrey for the efforts of docker image unification. > > +1 (non-binding) > > Best, > Yang > > Till Rohrmann 于2020年4月7日周二 下午11:04写道： > > > Thanks for driving this effort

[jira] [Created] (FLINK-17042) Jackson version conflict for Flink 1.9

Danny Chen created FLINK-17042: -- Summary: Jackson version conflict for Flink 1.9 Key: FLINK-17042 URL: https://issues.apache.org/jira/browse/FLINK-17042 Project: Flink Issue Type: Improvement

[VOTE] FLIP-120: Support conversion between PyFlink Table and Pandas DataFrame

Hi all, I'd like to start the vote for FLIP-120[1] which is discussed and reached consensus in the discussion thread[2]. The vote will be open for at least 72 hours unless there is an objection or we have not received sufficient votes. Regards, Dian [1]

[jira] [Created] (FLINK-17041) Migrate current TypeInformation creation to the TypeInformationExtractor framework

Guowei Ma created FLINK-17041: - Summary: Migrate current TypeInformation creation to the TypeInformationExtractor framework Key: FLINK-17041 URL: https://issues.apache.org/jira/browse/FLINK-17041

Re: [VOTE] FLIP-111: Docker image unification

Thanks Andrey for the efforts of docker image unification. +1 (non-binding) Best, Yang Till Rohrmann 于2020年4月7日周二 下午11:04写道： > Thanks for driving this effort Andrey. > > +1 (binding) > > Cheers, > Till > > On Tue, Apr 7, 2020 at 4:48 PM Ufuk Celebi wrote: > > > Thanks for starting this FLIP.

Re: [ANNOUNCE] Apache Flink Stateful Functions 2.0.0 released

Thanks a lot for the release and your great job, Gordon! Also thanks to everyone who made this release possible! Best, Congxian Oytun Tez 于2020年4月8日周三 上午2:55写道： > I should also add, I couldn't agree more with this sentence in the release > article: "state access/updates and messaging need to

[jira] [Created] (FLINK-17040) SavepointWriterITCase broken

Wenlong Lyu created FLINK-17040: --- Summary: SavepointWriterITCase broken Key: FLINK-17040 URL: https://issues.apache.org/jira/browse/FLINK-17040 Project: Flink Issue Type: Bug

Re: [VOTE] FLIP-108: Add GPU support in Flink

Thanks Yangze for the efforts to support GPU extended resources. +1 for this FLIP Best, Yang Till Rohrmann 于2020年4月2日周四 下午11:10写道： > Thanks for driving this effort Yangze. > > +1 > > Cheers, > Till > > On Wed, Apr 1, 2020 at 12:41 PM Canbin Zheng > wrote: > > > Thanks Yangze for driving the

[VOTE] FLIP-121: Support Cython Optimizing Python User Defined Function

Hi all, I would like to start the vote for FLIP-121[1], which is discussed and reached a consensus in the discussion thread[2]. The vote will be open for at least 72h, unless there is an objection or not enough votes. Best, Xingbo [1]

[jira] [Created] (FLINK-17039) Introduce TypeInformationExtractor interface

Guowei Ma created FLINK-17039: - Summary: Introduce TypeInformationExtractor interface Key: FLINK-17039 URL: https://issues.apache.org/jira/browse/FLINK-17039 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17038) Decouple resolving Type and creating TypeInformation process

Guowei Ma created FLINK-17038: - Summary: Decouple resolving Type and creating TypeInformation process Key: FLINK-17038 URL: https://issues.apache.org/jira/browse/FLINK-17038 Project: Flink

[jira] [Created] (FLINK-17037) add e2e tests for reading array data types from postgres with JDBCTableSource and PostgresCatalog

Bowen Li created FLINK-17037: Summary: add e2e tests for reading array data types from postgres with JDBCTableSource and PostgresCatalog Key: FLINK-17037 URL: https://issues.apache.org/jira/browse/FLINK-17037

Re: [DISCUSS] Consolidated log4j2-properties file

I also like the idea of getting rid of all those copies of the same file across our codebase. How about setting the log level in the log4j config file in flink-test-utils-junit/src/main/resources to INFO, and using a separate log4j config for local maven runs? (we pass a different log4j file in

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Thank you all :) > On Apr 7, 2020, at 9:31 AM, Igal Shilman wrote: > > Congrats Seth! > >> On Tuesday, April 7, 2020, Zhijiang >> wrote: >> >> Congratulations, Seth! >> >> Best, >> Zhijiang >> >> >> -- >> From:tison >> Send

Re: [ANNOUNCE] Apache Flink Stateful Functions 2.0.0 released

Thank you for managing the release, Gordon — you did a tremendous job! And to everyone else who worked on pushing it through. Really excited about the new use cases that StateFun 2.0 unlocks for Flink users and beyond! Marta On Tue, Apr 7, 2020 at 4:47 PM Hequn Cheng wrote: > Thanks a lot for

[jira] [Created] (FLINK-17036) Datadog forwarder does not allow for EU endpoint

Raymond Farrelly created FLINK-17036: Summary: Datadog forwarder does not allow for EU endpoint Key: FLINK-17036 URL: https://issues.apache.org/jira/browse/FLINK-17036 Project: Flink

Re: [DISCUSS]FLIP-113: Support SQL and planner hints

Thanks for the update Danny. +1 from my side. Regards, Timo On 07.04.20 13:25, Danny Chan wrote: Hi, every ~ It seems that we all agree to drop the idea for white/black list for each connector, and have a global config option to default disable this feature. I have also discussed with Timo

Re: [VOTE] FLIP-111: Docker image unification

Thanks for driving this effort Andrey. +1 (binding) Cheers, Till On Tue, Apr 7, 2020 at 4:48 PM Ufuk Celebi wrote: > Thanks for starting this FLIP. > > +1 > > On Tue, Apr 7, 2020 at 11:29 AM Andrey Zagrebin > wrote: > > > Hi All, > > > > As discussed in these threads [1] and [2], > > we

Re: [VOTE] FLIP-111: Docker image unification

Thanks for starting this FLIP. +1 On Tue, Apr 7, 2020 at 11:29 AM Andrey Zagrebin wrote: > Hi All, > > As discussed in these threads [1] and [2], > we suggest to unify the docker topic in Flink for users [3]. > > This mainly means refactoring of the existing code and introducing more > docs as

Re: [ANNOUNCE] Apache Flink Stateful Functions 2.0.0 released

Thanks a lot for the release and your great job, Gordon! Also thanks to everyone who made this release possible! Best, Hequn On Tue, Apr 7, 2020 at 8:58 PM Tzu-Li (Gordon) Tai wrote: > The Apache Flink community is very happy to announce the release of Apache > Flink Stateful Functions 2.0.0.

Re: [DISCUSS] FLIP-121: Support Cython Optimizing Python User Defined Function

Hi, +1 on integrating with Azure, it is consistent with the long term goal and we are also going to switch from Travis to Azure. The performance improvement is very impressive. Looking forward to the vote. Best, Hequn On Tue, Apr 7, 2020 at 9:10 PM Xingbo Huang wrote: > Hi everyone, > >

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congrats Seth! On Tuesday, April 7, 2020, Zhijiang wrote: > Congratulations, Seth! > > Best, > Zhijiang > > > -- > From:tison > Send Time:2020 Apr. 7 (Tue.) 19:26 > To:dev > Subject:Re: [ANNOUNCE] New Flink committer: Seth

[jira] [Created] (FLINK-17035) Replace FailoverTopology with SchedulingTopology

Gary Yao created FLINK-17035: Summary: Replace FailoverTopology with SchedulingTopology Key: FLINK-17035 URL: https://issues.apache.org/jira/browse/FLINK-17035 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-121: Support Cython Optimizing Python User Defined Function

Hi everyone, Thanks all of you for the discussion. If there are no objections, I would like to start a vote thread tomorrow. Best, Xingbo jincheng sun 于2020年4月7日周二 下午6:22写道： > Hi Xingbo, > > Thanks for bring up this discussion! > > I agree with Robert, +1 for integration with Azure. > > Best,

[ANNOUNCE] Apache Flink Stateful Functions 2.0.0 released

The Apache Flink community is very happy to announce the release of Apache Flink Stateful Functions 2.0.0. Stateful Functions is an API that simplifies building distributed stateful applications. It's based on functions with persistent state that can interact dynamically with strong consistency

Fwd: [DISCUSS] FLIP-71 - E2E View support in Flink SQL

forward the reply to ML too. *Best Regards,* *Zhenghua Gao* -- Forwarded message - From: Zhenghua Gao Date: Tue, Apr 7, 2020 at 8:40 PM Subject: Re: [DISCUSS] FLIP-71 - E2E View support in Flink SQL To: godfrey he >> regarding to "Interoperability between Flink and Hive is

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congratulations, Seth! Best, Zhijiang -- From:tison Send Time:2020 Apr. 7 (Tue.) 19:26 To:dev Subject:Re: [ANNOUNCE] New Flink committer: Seth Wiesman Congratulations, Seth! Best, tison. Yu Li 于2020年4月7日周二 下午6:57写道： >

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congratulations, Seth! Best, tison. Yu Li 于2020年4月7日周二 下午6:57写道： > Congratulations, Seth! > > Best Regards, > Yu > > > On Tue, 7 Apr 2020 at 18:16, Benchao Li wrote: > > > Congratulations~ > > > > Hequn Cheng 于2020年4月7日周二 下午5:22写道： > > > > > Congratulations Seth! > > > > > > Best, Hequn > >

Re: [DISCUSS]FLIP-113: Support SQL and planner hints

Hi, every ~ It seems that we all agree to drop the idea for white/black list for each connector, and have a global config option to default disable this feature. I have also discussed with Timo and Jark about the interface TableSourceTable.Context.getExecutionOptions and finally we decide to

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congratulations, Seth! Best Regards, Yu On Tue, 7 Apr 2020 at 18:16, Benchao Li wrote: > Congratulations~ > > Hequn Cheng 于2020年4月7日周二 下午5:22写道： > > > Congratulations Seth! > > > > Best, Hequn > > > > On Tue, Apr 7, 2020 at 4:11 PM Fabian Hueske wrote: > > > > > Congrats Seth! Well deserved

Re: [DISCUSS] FLIP-124: Add open/close and Collector to (De)SerializationSchema

On 07.04.20 08:45, Dawid Wysakowicz wrote: @Jark I was aware of the implementation of SinkFunction, but it was a conscious choice to not do it that way. Personally I am against giving a default implementation to both the new and old methods. This results in an interface that by default does

Re: [DISCUSS] FLIP-121: Support Cython Optimizing Python User Defined Function

Hi Xingbo, Thanks for bring up this discussion! I agree with Robert, +1 for integration with Azure. Best, Jincheng Dian Fu 于2020年4月7日周二 下午2:21写道： > Hi Xingbo, > > Thanks a lot for the great work. Big +1 to this feature. The performance > improvement is impressive. > > Regards, > Dian > > > 在

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congratulations~ Hequn Cheng 于2020年4月7日周二 下午5:22写道： > Congratulations Seth! > > Best, Hequn > > On Tue, Apr 7, 2020 at 4:11 PM Fabian Hueske wrote: > > > Congrats Seth! Well deserved :-) > > > > Cheers, Fabian > > > > Am Di., 7. Apr. 2020 um 10:09 Uhr schrieb Yangze Guo >: > > > > >

[jira] [Created] (FLINK-17034) Execute the container CMD under TINI for better hygiene

Canbin Zheng created FLINK-17034: Summary: Execute the container CMD under TINI for better hygiene Key: FLINK-17034 URL: https://issues.apache.org/jira/browse/FLINK-17034 Project: Flink

[jira] [Created] (FLINK-17033) Upgrade OpenJDK docker image for Kubernetes

Canbin Zheng created FLINK-17033: Summary: Upgrade OpenJDK docker image for Kubernetes Key: FLINK-17033 URL: https://issues.apache.org/jira/browse/FLINK-17033 Project: Flink Issue Type:

[VOTE] FLIP-111: Docker image unification

Hi All, As discussed in these threads [1] and [2], we suggest to unify the docker topic in Flink for users [3]. This mainly means refactoring of the existing code and introducing more docs as a first step. The effort should enable further improvements and follow-ups for the docker integration

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congratulations Seth! Best, Hequn On Tue, Apr 7, 2020 at 4:11 PM Fabian Hueske wrote: > Congrats Seth! Well deserved :-) > > Cheers, Fabian > > Am Di., 7. Apr. 2020 um 10:09 Uhr schrieb Yangze Guo : > > > Congratulations Seth! > > > > Best, > > Yangze Guo > > > > On Tue, Apr 7, 2020 at 4:07 PM

Re: [DISCUSS] FLIP-111: Docker image unification

Hi all, Thanks for the further feedback Niels and Canbin. @Niels I agree with Till, the comments about docker tags are valid concerns and we can discuss them in dedicated ML threads in parallel or after the general unification of Dockerfiles suggested by this FLIP. One thing to add about point

[jira] [Created] (FLINK-17032) Naming convention unification for all the Kubernetes Resources

Canbin Zheng created FLINK-17032: Summary: Naming convention unification for all the Kubernetes Resources Key: FLINK-17032 URL: https://issues.apache.org/jira/browse/FLINK-17032 Project: Flink

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congrats Seth! Well deserved :-) Cheers, Fabian Am Di., 7. Apr. 2020 um 10:09 Uhr schrieb Yangze Guo : > Congratulations Seth! > > Best, > Yangze Guo > > On Tue, Apr 7, 2020 at 4:07 PM Jiayi Liao wrote: > > > > > > > > Congratulations Seth :) > > > > > > >

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congratulations Seth! Best, Yangze Guo On Tue, Apr 7, 2020 at 4:07 PM Jiayi Liao wrote: > > > > > Congratulations Seth :) > > > >

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

> > Congratulations Seth :) > >

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congrats Seth! Cheers, Till On Tue, Apr 7, 2020 at 9:50 AM Danny Chan wrote: > Congratulations ~ > > Best, > Danny Chan > 在 2020年4月7日 +0800 PM2:56，Congxian Qiu ，写道： > > Congratulations, Seth! > > > > Best, > > Congxian > > > > > > Kurt Young 于2020年4月7日周二 下午2:53写道： > > > > > Congratulations,

[jira] [Created] (FLINK-17031) HiveTableSourceTest fails with: "Timeout waiting for HMS to start"

Robert Metzger created FLINK-17031: -- Summary: HiveTableSourceTest fails with: "Timeout waiting for HMS to start" Key: FLINK-17031 URL: https://issues.apache.org/jira/browse/FLINK-17031 Project:

[jira] [Created] (FLINK-17030) Add primary key syntax to DDL

Timo Walther created FLINK-17030: Summary: Add primary key syntax to DDL Key: FLINK-17030 URL: https://issues.apache.org/jira/browse/FLINK-17030 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17028) Introduce a new HBase connector with new property keys

Jark Wu created FLINK-17028: --- Summary: Introduce a new HBase connector with new property keys Key: FLINK-17028 URL: https://issues.apache.org/jira/browse/FLINK-17028 Project: Flink Issue Type:

[jira] [Created] (FLINK-17027) Introduce a new Elasticsearch connector with new property keys

Jark Wu created FLINK-17027: --- Summary: Introduce a new Elasticsearch connector with new property keys Key: FLINK-17027 URL: https://issues.apache.org/jira/browse/FLINK-17027 Project: Flink Issue

[jira] [Created] (FLINK-17026) Introduce a new Kafka connector with new property keys

Jark Wu created FLINK-17026: --- Summary: Introduce a new Kafka connector with new property keys Key: FLINK-17026 URL: https://issues.apache.org/jira/browse/FLINK-17026 Project: Flink Issue Type:

[RESULT][VOTE] FLIP-122: New Connector Property Keys for New Factory

Hi all, The voting time for FLIP-122 has passed. I'm closing the vote now. There were 8 +1 votes, 4 of which are binding: - Timo (binding) - Dawid (binding) - Benchao Li (non-binding) - Jingsong Li (binding) - LakeShen (non-binding) - Leonard Xu (non-binding) - zoudan (non-binding) - Jark

[jira] [Created] (FLINK-17024) Make RpcEndpoint#getRpcService#getExecutor return a custom thread pool

Yang Wang created FLINK-17024: - Summary: Make RpcEndpoint#getRpcService#getExecutor return a custom thread pool Key: FLINK-17024 URL: https://issues.apache.org/jira/browse/FLINK-17024 Project: Flink

[jira] [Created] (FLINK-17023) The format checking of extractExecutionParams in config.sh is incorrect

Caizhi Weng created FLINK-17023: --- Summary: The format checking of extractExecutionParams in config.sh is incorrect Key: FLINK-17023 URL: https://issues.apache.org/jira/browse/FLINK-17023 Project: Flink

Re: [DISCUSS] FLIP-124: Add open/close and Collector to (De)SerializationSchema

Thanks for the explanation. Sounds good to me. Best, Jark On Tue, 7 Apr 2020 at 14:45, Dawid Wysakowicz wrote: > Hi all, > > @Timo I'm fine with OpenContext. > > @Timo @Seth Sure we can combine all the parameters in a single object. > Will update the FLIP > > @Jark I was aware of the

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congratulations, Seth! Best, Congxian Kurt Young 于2020年4月7日周二 下午2:53写道： > Congratulations, Seth! > > Best, > Kurt > > > On Tue, Apr 7, 2020 at 2:51 PM Jingsong Li wrote: > > > Congratulations Seth! > > > > Best, > > Jingsong Lee > > > > On Tue, Apr 7, 2020 at 2:46 PM Dawid Wysakowicz > >

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congratulations, Seth! Best, Kurt On Tue, Apr 7, 2020 at 2:51 PM Jingsong Li wrote: > Congratulations Seth! > > Best, > Jingsong Lee > > On Tue, Apr 7, 2020 at 2:46 PM Dawid Wysakowicz > wrote: > > > Congratulations Seth. Happy to have you in the community! > > > > Best, > > > > Dawid > > >

[jira] [Created] (FLINK-17022) Flink SQL ROW_NUMBER() Exception: TableException: This calc has no useful projection and no filter. It should be removed by CalcRemoveRule.

xingoo created FLINK-17022: -- Summary: Flink SQL ROW_NUMBER() Exception: TableException: This calc has no useful projection and no filter. It should be removed by CalcRemoveRule. Key: FLINK-17022 URL:

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congratulations, Seth! Thanks, Zhu Zhu Dian Fu 于2020年4月7日周二 下午2:43写道： > Congratulations! > > > 在 2020年4月7日，下午2:35，Konstantin Knauf 写道： > > > > Congratulations, Seth! Well deserved :) > > > > On Tue, Apr 7, 2020 at 8:33 AM Tzu-Li (Gordon) Tai > > wrote: > > > >> Hi everyone! > >> > >> On

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congratulations Seth. Happy to have you in the community! Best, Dawid On 07/04/2020 08:43, Dian Fu wrote: > Congratulations! > >> 在 2020年4月7日，下午2:35，Konstantin Knauf 写道： >> >> Congratulations, Seth! Well deserved :) >> >> On Tue, Apr 7, 2020 at 8:33 AM Tzu-Li (Gordon) Tai >> wrote: >> >>> Hi

Re: [DISCUSS] FLIP-124: Add open/close and Collector to (De)SerializationSchema

Hi all, @Timo I'm fine with OpenContext. @Timo @Seth Sure we can combine all the parameters in a single object. Will update the FLIP @Jark I was aware of the implementation of SinkFunction, but it was a conscious choice to not do it that way. Personally I am against giving a default

[jira] [Created] (FLINK-17021) Blink Planner set GlobalDataExchangeMode

Zhu Zhu created FLINK-17021: --- Summary: Blink Planner set GlobalDataExchangeMode Key: FLINK-17021 URL: https://issues.apache.org/jira/browse/FLINK-17021 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congratulations! > 在 2020年4月7日，下午2:35，Konstantin Knauf 写道： > > Congratulations, Seth! Well deserved :) > > On Tue, Apr 7, 2020 at 8:33 AM Tzu-Li (Gordon) Tai > wrote: > >> Hi everyone! >> >> On behalf of the PMC, I’m very happy to announce Seth Wiesman as a new >> Flink committer. >> >>

[jira] [Created] (FLINK-17020) Introduce GlobalDataExchangeMode for JobGraph Generation

Zhu Zhu created FLINK-17020: --- Summary: Introduce GlobalDataExchangeMode for JobGraph Generation Key: FLINK-17020 URL: https://issues.apache.org/jira/browse/FLINK-17020 Project: Flink Issue Type:

[jira] [Created] (FLINK-17019) Implement FIFO Physical Slot Assignment in SlotPoolImpl

Zhu Zhu created FLINK-17019: --- Summary: Implement FIFO Physical Slot Assignment in SlotPoolImpl Key: FLINK-17019 URL: https://issues.apache.org/jira/browse/FLINK-17019 Project: Flink Issue Type:

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congratulations, Seth! Well deserved :) On Tue, Apr 7, 2020 at 8:33 AM Tzu-Li (Gordon) Tai wrote: > Hi everyone! > > On behalf of the PMC, I’m very happy to announce Seth Wiesman as a new > Flink committer. > > Seth started contributing to the project in March 2017. You may know him > from

[ANNOUNCE] New Flink committer: Seth Wiesman

Hi everyone! On behalf of the PMC, I’m very happy to announce Seth Wiesman as a new Flink committer. Seth started contributing to the project in March 2017. You may know him from several contributions in the past. He had helped a lot with Flink documentation, and had contributed the State

[jira] [Created] (FLINK-17018) Use Bulk Slot Allocation in DefaultExecutionSlotAllocator

Zhu Zhu created FLINK-17018: --- Summary: Use Bulk Slot Allocation in DefaultExecutionSlotAllocator Key: FLINK-17018 URL: https://issues.apache.org/jira/browse/FLINK-17018 Project: Flink Issue Type:

Re: [VOTE] FLIP-84: Improve & Refactor API of TableEnvironment & Table

+1 Best, Dawid On 07/04/2020 07:44, godfrey he wrote: > Hi, Kurt > > yes. `TableEnvironement#executeSql` also could execute `SELECT` statement, > which is similar to `Table#execute`. > I add this to the document. > > Best, > Godfrey > > Kurt Young 于2020年4月7日周二 上午11:52写道： > >> +1 (binding) >>

[jira] [Created] (FLINK-17017) Implement Bulk Slot Allocation in SchedulerImpl

Zhu Zhu created FLINK-17017: --- Summary: Implement Bulk Slot Allocation in SchedulerImpl Key: FLINK-17017 URL: https://issues.apache.org/jira/browse/FLINK-17017 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] FLIP-121: Support Cython Optimizing Python User Defined Function

Hi Xingbo, Thanks a lot for the great work. Big +1 to this feature. The performance improvement is impressive. Regards, Dian > 在 2020年4月7日，下午12:38，Robert Metzger 写道： > > Thank you for posting the FLIP. > > The proposed integration with Azure Pipelines looks good to me. > > On Tue, Mar 31,

[jira] [Created] (FLINK-17015) Fix NPE from NullAwareMapIterator

Jark Wu created FLINK-17015: --- Summary: Fix NPE from NullAwareMapIterator Key: FLINK-17015 URL: https://issues.apache.org/jira/browse/FLINK-17015 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17014) Implement PipelinedRegionSchedulingStrategy

Zhu Zhu created FLINK-17014: --- Summary: Implement PipelinedRegionSchedulingStrategy Key: FLINK-17014 URL: https://issues.apache.org/jira/browse/FLINK-17014 Project: Flink Issue Type: Sub-task