Re: [DISCUSS] FLIP-291: Externalized Declarative Resource Management

Hi everyone, @Shammon I'm not entirely sure what "config file" you're referring to. You can, of course, override the default parallelism in "flink-conf.yaml", but for sinks and sources, the parallelism needs to be tweaked on the connector level ("WITH" statement). This is something that should

Re: [DISCUSS] FLIP-287: Extend Sink#InitContext to expose ExecutionConfig and JobID

Hi Konstantin, I checked the usage of ExecutionConfig in Kinesis and KafKa sinks: - Kinesis sink: ExecutionConfig is not used by Kinesis sink. The one that uses getAutoWatermarkInterval is the Kinesis Source, Joao may have made a mistake. - Kafka sink: isObjectReuseEnabled and ExecutionConfig are

[jira] [Created] (FLINK-31031) Disable the output buffer of Python process to make it more convenient for interactive users

Dian Fu created FLINK-31031: --- Summary: Disable the output buffer of Python process to make it more convenient for interactive users Key: FLINK-31031 URL: https://issues.apache.org/jira/browse/FLINK-31031

[jira] [Created] (FLINK-31030) Support more binary classification evaluation metrics.

Fan Hong created FLINK-31030: Summary: Support more binary classification evaluation metrics. Key: FLINK-31030 URL: https://issues.apache.org/jira/browse/FLINK-31030 Project: Flink Issue Type:

[jira] [Created] (FLINK-31029) KBinsDiscretizer gives wrong bin edges when input data contains only 2 distinct values

Fan Hong created FLINK-31029: Summary: KBinsDiscretizer gives wrong bin edges when input data contains only 2 distinct values Key: FLINK-31029 URL: https://issues.apache.org/jira/browse/FLINK-31029

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congratulations, Weijie! Best, Weihua > On Feb 13, 2023, at 11:55, Lijie Wang wrote: > > Congratulations, Weijie!

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congratulations, Weijie! Best, Hang Samrat Deb 于2023年2月13日周一 12:40写道： > Congratulations, Weijie! > > On Mon, 13 Feb 2023 at 10:08 AM, Benchao Li wrote: > > > Congratulations, Weijie! > > > > Rui Fan <1996fan...@gmail.com> 于2023年2月13日周一 12:27写道： > > > > > Congratulations, Weijie! > > > > > >

[jira] [Created] (FLINK-31028) Provide different compression methods for per level

Jun Zhang created FLINK-31028: - Summary: Provide different compression methods for per level Key: FLINK-31028 URL: https://issues.apache.org/jira/browse/FLINK-31028 Project: Flink Issue Type:

[jira] [Created] (FLINK-31027) Introduce annotation for table store

Shammon created FLINK-31027: --- Summary: Introduce annotation for table store Key: FLINK-31027 URL: https://issues.apache.org/jira/browse/FLINK-31027 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congratulations, Weijie! On Mon, 13 Feb 2023 at 10:08 AM, Benchao Li wrote: > Congratulations, Weijie! > > Rui Fan <1996fan...@gmail.com> 于2023年2月13日周一 12:27写道： > > > Congratulations, Weijie! > > > > Best > > Rui Fan > > > > On Mon, Feb 13, 2023 at 12:20 Yuxin Tan wrote: > > > > >

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congratulations, Weijie! Rui Fan <1996fan...@gmail.com> 于2023年2月13日周一 12:27写道： > Congratulations, Weijie! > > Best > Rui Fan > > On Mon, Feb 13, 2023 at 12:20 Yuxin Tan wrote: > > > Congratulations, Weijie! > > > > Best, > > Yuxin > > > > > > Yanfei Lei 于2023年2月13日周一 12:16写道： > > > > >

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congratulations, Weijie! Best Rui Fan On Mon, Feb 13, 2023 at 12:20 Yuxin Tan wrote: > Congratulations, Weijie! > > Best, > Yuxin > > > Yanfei Lei 于2023年2月13日周一 12:16写道： > > > Congratulations, Weijie! > > > > Best regards, > > Yanfei > > > > Junrui Lee 于2023年2月13日周一 12:12写道： > > > > > >

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congratulations, Weijie! Best, Yuxin Yanfei Lei 于2023年2月13日周一 12:16写道： > Congratulations, Weijie! > > Best regards, > Yanfei > > Junrui Lee 于2023年2月13日周一 12:12写道： > > > > Congratulations, Weijie! > > > > Best, > > Junrui >

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congratulations, Weijie! Best regards, Yanfei Junrui Lee 于2023年2月13日周一 12:12写道： > > Congratulations, Weijie! > > Best, > Junrui

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congratulations, Weijie! Best, Junrui

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congratulations, Weijie! Best regards, Yuxia - 原始邮件 - 发件人: "Shammon FY" 收件人: "dev" 发送时间: 星期一, 2023年 2 月 13日 下午 12:05:09 主题: Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo Congratulations, Weijie! Best, Shammon On Mon, Feb 13, 2023 at 12:03 PM Geng Biao wrote: > Congrats,

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congratulations, Weijie! Best, Shammon On Mon, Feb 13, 2023 at 12:03 PM Geng Biao wrote: > Congrats, weijie! > Best, > Biao Geng > > 获取 Outlook for iOS > > 发件人: Lijie Wang > 发送时间: Monday, February 13, 2023 11:55:56 AM > 收件人:

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congrats, weijie! Best, Biao Geng 获取 Outlook for iOS 发件人: Lijie Wang 发送时间: Monday, February 13, 2023 11:55:56 AM 收件人: dev@flink.apache.org 主题: Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo Congratulations, Weijie! Best, Lijie

[jira] [Created] (FLINK-31026) KBinsDiscretizer should gives binEdges wrong bin edges when all values are same.

Fan Hong created FLINK-31026: Summary: KBinsDiscretizer should gives binEdges wrong bin edges when all values are same. Key: FLINK-31026 URL: https://issues.apache.org/jira/browse/FLINK-31026 Project:

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congratulations, Weijie! Best, Lijie Xintong Song 于2023年2月13日周一 11:45写道： > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Weijie Guo as a new Flink > committer. > > Weijie has been consistently contributing to the project for over 1 year. > He mainly works on Flink runtime

[ANNOUNCE] New Apache Flink Committer - Weijie Guo

Hi everyone, On behalf of the PMC, I'm very happy to announce Weijie Guo as a new Flink committer. Weijie has been consistently contributing to the project for over 1 year. He mainly works on Flink runtime and shuffle parts. He has authored 66 PRs and reviewed 34 PRs. He is the major contributor

[VOTE] FLIP-289: Support online inference (Flink ML)

Hi all, We would like to start the vote for FLIP-289: Support online inference (Flink ML) [1]. This FLIP was discussed in this thread [2]. The goal of this FLIP is to enable users to use the model trained by Flink ML to do online inference. The vote will be open until at least Feb 16th (at

[jira] [Created] (FLINK-31025) Release Testing: Verify FLINK-30650 Introduce EXPLAIN PLAN_ADVICE to provide SQL advice

Jane Chan created FLINK-31025: - Summary: Release Testing: Verify FLINK-30650 Introduce EXPLAIN PLAN_ADVICE to provide SQL advice Key: FLINK-31025 URL: https://issues.apache.org/jira/browse/FLINK-31025

Re: Confusion about some overlapping functionality of SupportsProjectionPushDown and SupportsReadingMetadata

hi. yuxia, Shengkai. thanks for your explanation. I originally wanted to say whether we can let SupportsReadingMetadata handle the metadata column alone (may provide an ability to merge 2 produced types), so that the 2 interfaces don't matter. But through your explanation on the planner side

Re: Confusion about some overlapping functionality of SupportsProjectionPushDown and SupportsReadingMetadata

Sorry for the misktake, correct it. "but I'm afraid that we have no other better way to avoid it. Best regards, Yuxia - 原始邮件 - 发件人: "yuxia" 收件人: "dev" 发送时间: 星期一, 2023年 2 月 13日 上午 10:11:53 主题: Re: Confusion about some overlapping functionality of SupportsProjectionPushDown and

Re: Confusion about some overlapping functionality of SupportsProjectionPushDown and SupportsReadingMetadata

Hi, Ran Tao. I agree to Shengkai that physical column pushdown and metadata processing are different things and should be processed separately. To me, it'll be more weird that SupportsReadingMetadata do the both. I agree you that that the developer may have unexpected behaviors due to the