[jira] [Created] (FLINK-21224) Remove BatchExecExchange and StreamExecExchange, and replace their functionality with ExecEdge

godfrey he created FLINK-21224: -- Summary: Remove BatchExecExchange and StreamExecExchange, and replace their functionality with ExecEdge Key: FLINK-21224 URL: https://issues.apache.org/jira/browse/FLINK-21224

[jira] [Created] (FLINK-21223) Support to specify the input/output types of Python UDFs via string

Dian Fu created FLINK-21223: --- Summary: Support to specify the input/output types of Python UDFs via string Key: FLINK-21223 URL: https://issues.apache.org/jira/browse/FLINK-21223 Project: Flink

Re: [DISCUSS] FLINK-21045: Support 'load module' and 'unload module' SQL syntax

Thanks Jane for the summary and starting the discussion in the mailing list. Here are my thoughts: 1) syntax to reorder modules I agree with Rui Li it would be quite useful if we can have some syntax to reorder modules. I slightly prefer `USE MODULES x, y, z` than `RELOAD MODULES x, y, z`,

[jira] [Created] (FLINK-21222) Support loopback mode to allow Python UDF worker and client reuse the same Python VM

Dian Fu created FLINK-21222: --- Summary: Support loopback mode to allow Python UDF worker and client reuse the same Python VM Key: FLINK-21222 URL: https://issues.apache.org/jira/browse/FLINK-21222 Project:

Re: [DISCUSS]FLIP-163: SQL Client Improvements

Thanks Shengkai for the update! The proposed changes look good to me. On Fri, Jan 29, 2021 at 8:26 PM Shengkai Fang wrote: > Hi, Rui. > You are right. I have already modified the FLIP. > > The main changes: > > # -f parameter has no restriction about the statement type. > Sometimes, users use

Re: [VOTE] FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements

+1 (binding) Thank you~ Xintong Song On Mon, Feb 1, 2021 at 11:56 AM Yangze Guo wrote: > Hi everyone, > > I'd like to start the vote of FLIP-156 [1]. This FLIP is discussed in > the thread[2]. > > The vote will be open for at least 72 hours. Unless there is an objection, > I will try to

Re: [ANNOUNCE] Apache Flink 1.10.3 released

Thanks Xintong for being the release manager and everyone who helped with the release! Cheers, Zhu Dian Fu 于2021年1月29日周五 下午5:56写道： > Thanks Xintong for driving this release! > > Regards, > Dian > > 在 2021年1月29日，下午5:24，Till Rohrmann 写道： > > Thanks Xintong for being our release manager. Well

[VOTE] FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements

Hi everyone, I'd like to start the vote of FLIP-156 [1]. This FLIP is discussed in the thread[2]. The vote will be open for at least 72 hours. Unless there is an objection, I will try to close it by February 4, 2021 if we have received sufficient votes. [1]

Re: [DISCUSS] FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements

Thanks for reply, Till and Xintong! I update the FLIP, including: - Edit the JavaDoc of the proposed StreamGraphGenerator#setSlotSharingGroupResource. - Add "Future Plan" section, which contains the potential follow-up issues and the limitations to be documented when fine-grained resource

[jira] [Created] (FLINK-21221) Deduplication of ResourceCounter

Yangze Guo created FLINK-21221: -- Summary: Deduplication of ResourceCounter Key: FLINK-21221 URL: https://issues.apache.org/jira/browse/FLINK-21221 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21220) Change the type of cpuCores in ResourceProfile to CPUResource

Yangze Guo created FLINK-21220: -- Summary: Change the type of cpuCores in ResourceProfile to CPUResource Key: FLINK-21220 URL: https://issues.apache.org/jira/browse/FLINK-21220 Project: Flink

Re: [VOTE] FLIP-159: Reactive Mode

+1 (binding) Thanks, Zhu Till Rohrmann 于2021年1月29日周五 下午10:23写道： > LGTM. Thanks for the work Robert! > > +1 (binding) > > Cheers, > Till > > On Thu, Jan 28, 2021 at 11:27 AM Yang Wang wrote: > > > Thanks Robert for your great work on this FLIP. This is really a big step > > to make Flink auto

Re: [VOTE] FLIP-160: Declarative scheduler

+1 (binding) Thanks, Zhu Yang Wang 于2021年2月1日周一 上午11:04写道： > +1 (non-binding) > > Best, > Yang > > Yangze Guo 于2021年2月1日周一 上午9:50写道： > > > +1 (non-binding) > > > > Best, > > Yangze Guo > > > > On Sat, Jan 30, 2021 at 8:40 AM Xintong Song > > wrote: > > > > > > +1 (binding) > > > > > > Thank

Re: [VOTE] FLIP-160: Declarative scheduler

+1 (non-binding) Best, Yang Yangze Guo 于2021年2月1日周一 上午9:50写道： > +1 (non-binding) > > Best, > Yangze Guo > > On Sat, Jan 30, 2021 at 8:40 AM Xintong Song > wrote: > > > > +1 (binding) > > > > Thank you~ > > > > Xintong Song > > > > > > > > On Fri, Jan 29, 2021 at 10:41 PM Robert Metzger >

Re: [VOTE] FLIP-160: Declarative scheduler

+1 (non-binding) Best, Yangze Guo On Sat, Jan 30, 2021 at 8:40 AM Xintong Song wrote: > > +1 (binding) > > Thank you~ > > Xintong Song > > > > On Fri, Jan 29, 2021 at 10:41 PM Robert Metzger wrote: > > > ... and thanks a lot for your work :) I'm really excited about finally > > adding this

Re: [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior

I also prefer to not expand this FLIP further, but we could open a discussion thread right after this FLIP being accepted and start coding & reviewing. Make technique discussion and coding more pipelined will improve efficiency. Best, Kurt On Sat, Jan 30, 2021 at 3:47 PM Leonard Xu wrote: >

[jira] [Created] (FLINK-21219) FlinkKafkaConsumer ignores offset overrides for new topics when restoring from savepoint.

Dominik Wosiński created FLINK-21219: Summary: FlinkKafkaConsumer ignores offset overrides for new topics when restoring from savepoint. Key: FLINK-21219 URL: https://issues.apache.org/jira/browse/FLINK-21219