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

Hi everyone, Thanks all for the votes. So far, we have - 3 binding +1 votes (Timo, Kurt, Dawid) - 1 non-binding +1 votes (Terry) - No -1 votes The voting time has past and there is enough +1 votes to consider the FLIP-84 approved. Thank you all. Best, Godfrey Dawid Wysakowicz 于2020年

[jira] [Created] (FLINK-17045) If multiple views are based on tables not defined in the yaml config file, dropping one of the views will throw exception

Caizhi Weng created FLINK-17045: --- Summary: If multiple views are based on tables not defined in the yaml config file, dropping one of the views will throw exception Key: FLINK-17045 URL: https://issues.apache.org/ji

Re: [ANNOUNCE] Apache Flink Stateful Functions 2.0.0 released

Great news! Thanks a lot for being our release manager Gordon and to everyone who helped with the release. Cheers, Till On Wed, Apr 8, 2020 at 3:57 AM Congxian Qiu wrote: > Thanks a lot for the release and your great job, Gordon! > Also thanks to everyone who made this release possible! > > Bes

Re: [DISCUSS] FLIP-105: Support to Interpret and Emit Changelog in Flink SQL

One minor comment, is there any other encoding or format in debezium? I'm asking because the format name is debezium-json, i'm wondering whether debezium is enough. This also applies to canal. Best, Kurt On Tue, Apr 7, 2020 at 11:49 AM Jark Wu wrote: > Hi everyone, > > Since this FLIP was prop

Re: [DISCUSS] FLIP-123: DDL and DML compatibility for Hive connector

Hi Rui, Thanks for bringing up this discussion and it makes sense to me though i have one comment about the FLIP. There are a few places in the design document saying some features will not be supported or not included in this FLIP, but I don't get what will be supported exactly. I can imagine oth

[jira] [Created] (FLINK-17044) FLIP-108: Add GPU support in Flink

Yangze Guo created FLINK-17044: -- Summary: FLIP-108: Add GPU support in Flink Key: FLINK-17044 URL: https://issues.apache.org/jira/browse/FLINK-17044 Project: Flink Issue Type: New Feature

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 ever

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 be

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

+1 for the proposal, a small concern for drop view statement: dropViewStatement:   DROP VIEW name [ IF EXISTS ] I think the drop statement should be DROP VIEW [ IF EXISTS ] name Best, Danny Chan 在 2020年4月8日 +0800 AM11:54，Kurt Young ，写道： > This FLIP seems to be quite straightforward, +1 from m

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 implementat

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 description

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 A

[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] https://cwiki.apache.org/confluence/di

[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 Project:

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

+1 (binding) > 在 2020年4月8日，上午9:53，Xingbo Huang 写道： > > 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, >

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 b

[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 Report

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] https://cwiki.apache.org/confluence/display/FLINK/FLIP-121%3A

[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 Issue

[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 th

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 Issu

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 a

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 sugge

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, > > Thanks

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 Wiesman

[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: Sub-task

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 gu

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 n

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写道： > Congra

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 intr

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 not

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 >: > > > > > Congratula

[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 Issu

[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: Impro

[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 wit

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, Se

[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: Flink

Re: [ANNOUNCE] New Flink committer: Seth Wiesman

Congratulations ~ Best, Danny Chan 在 2020年4月7日 +0800 PM2:56，Congxian Qiu ，写道： > 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: > > > > > Congratu

[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

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

Hi Dawid, thanks for driving this. big +1 for this flip. Currently we have to implement an internal flat map in connectors, which is very inconvenient to support customized parser in DDL. Here is my minor suggestions: 1. Can we support serialize/deserialize from/to a message with a specified type

[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: Sub-

[jira] [Created] (FLINK-17029) Introduce a new JDBC connector with new property keys

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

[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 T

[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: Sub-

[jira] [Created] (FLINK-17025) Introduce new set of connectors using new property keys and new factory interface

Jark Wu created FLINK-17025: --- Summary: Introduce new set of connectors using new property keys and new factory interface Key: FLINK-17025 URL: https://issues.apache.org/jira/browse/FLINK-17025 Project: Flin

[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 (bindi

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

+1 (binding) Best, Jark On Sun, 5 Apr 2020 at 16:38, zoudan wrote: > +1 (non-binding) > > Best, > Dan Zou > > > > 在 2020年4月3日，10:02，LakeShen 写道： > > > > +1 (non-binding) > >

[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