Re: [VOTE] FLIP-241: Completed Jobs Information Enhancement

+1 (binding) Best, Yangze Guo On Thu, Jun 23, 2022 at 1:07 PM junhan yang wrote: > > Hi everyone, > > Thanks for the feedbacks on the discussion thread[1]. I would like to start > a vote thread here for FLIP-241: Completed Jobs Information Enhancement[2]. > > The vote will last for at least 72

[jira] [Created] (FLINK-28215) Bump Maven Surefire plugin to 3.0.0-M7

Martijn Visser created FLINK-28215: -- Summary: Bump Maven Surefire plugin to 3.0.0-M7 Key: FLINK-28215 URL: https://issues.apache.org/jira/browse/FLINK-28215 Project: Flink Issue Type:

Re: [VOTE] FLIP-221: Abstraction for lookup source and metric

+1 (binding) Best, Jark On Thu, 23 Jun 2022 at 12:49, Qingsheng Ren wrote: > Hi devs, > > I’d like to start a vote thread for FLIP-221: Abstraction for lookup > source and metric. You can find the discussion thread in [2]*. > > The vote will be open for at least 72 hours unless there is an

[jira] [Created] (FLINK-28214) ArrayDataSerializer can not be reused to copy customized type of array data

Yi Tang created FLINK-28214: --- Summary: ArrayDataSerializer can not be reused to copy customized type of array data Key: FLINK-28214 URL: https://issues.apache.org/jira/browse/FLINK-28214 Project: Flink

[VOTE] FLIP-241: Completed Jobs Information Enhancement

Hi everyone, Thanks for the feedbacks on the discussion thread[1]. I would like to start a vote thread here for FLIP-241: Completed Jobs Information Enhancement[2]. The vote will last for at least 72 hours unless there is an objection, I will try to close it by *next Tuesday* if we receive

Re: [DISCUSS] FLIP-241: Completed Jobs Information Enhancement

Hi all, Thank you all for your feedbacks. As far as I can see, it looks like the discussion on this FLIP has been converged. I will start a new vote thread now. Best regards, Junhan Yangze Guo 于2022年6月17日周五 14:05写道： > Thanks for the input, Jiangang. > > I think it's a valid demand to

[VOTE] FLIP-221: Abstraction for lookup source and metric

Hi devs, I’d like to start a vote thread for FLIP-221: Abstraction for lookup source and metric. You can find the discussion thread in [2]*. The vote will be open for at least 72 hours unless there is an objection or not enough binding votes. Thanks everyone participating in the discussion!

Re: [DISCUSS] Maintain a Calcite repository for Flink to accelerate the development for Flink SQL features

Hi Martijin, This is really exciting news. Thanks a lot for the effort to improve collaboration and communication with the Calcite community. > My take away from the discussion in the Flink community and the discussion in the Calcite community is that I believe we should do 3 things. Agreed on

[jira] [Created] (FLINK-28213) StreamExecutionEnvironment configure method support override pipeline.jars option

dalongliu created FLINK-28213: - Summary: StreamExecutionEnvironment configure method support override pipeline.jars option Key: FLINK-28213 URL: https://issues.apache.org/jira/browse/FLINK-28213 Project:

[jira] [Created] (FLINK-28212) IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect

luoyuxia created FLINK-28212: Summary: IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect Key: FLINK-28212 URL:

[jira] [Created] (FLINK-28211) Rename Schema to TableSchema

Jingsong Lee created FLINK-28211: Summary: Rename Schema to TableSchema Key: FLINK-28211 URL: https://issues.apache.org/jira/browse/FLINK-28211 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28210) FlinkSessionJob fails after FlinkDeployment is updated

Daniel Crowe created FLINK-28210: Summary: FlinkSessionJob fails after FlinkDeployment is updated Key: FLINK-28210 URL: https://issues.apache.org/jira/browse/FLINK-28210 Project: Flink Issue

[DISCUSS] Releasing Flink ML 2.1.0

Hi devs, Yun and I would like to start a discussion for releasing Flink ML 2.1.0. In the past few months, we focused on improving the infra (e.g. memory management, benchmark infra, online training, python support) of Flink ML by implementing, benchmarking,

[jira] [Created] (FLINK-28209) KafkaSink with EXACTLY_ONCE produce reduplicate data(flink kafka connector1.14.4)

tanyao created FLINK-28209: -- Summary: KafkaSink with EXACTLY_ONCE produce reduplicate data(flink kafka connector1.14.4) Key: FLINK-28209 URL: https://issues.apache.org/jira/browse/FLINK-28209 Project:

[jira] [Created] (FLINK-28208) The method createBatchSink in class HiveTableSink should setParallelism for map operator

Liu created FLINK-28208: --- Summary: The method createBatchSink in class HiveTableSink should setParallelism for map operator Key: FLINK-28208 URL: https://issues.apache.org/jira/browse/FLINK-28208 Project:

[DISCUSS] FLIP-243: Dedicated Opensearch connectors

Hi Folks, We would like to start a discussion thread on FLIP-243: Dedicated Opensearch connectors [1], [2] where we propose to provide dedicated connectors for Opensearch [3], on par with existing Elasticsearch ones. Looking forward to comments and feedback. Thank you. [1]

[jira] [Created] (FLINK-28207) Disabling webhook should also disable mutator

Márton Balassi created FLINK-28207: -- Summary: Disabling webhook should also disable mutator Key: FLINK-28207 URL: https://issues.apache.org/jira/browse/FLINK-28207 Project: Flink Issue

[jira] [Created] (FLINK-28206) EOFException on Checkpoint Recovery

uharaqo created FLINK-28206: --- Summary: EOFException on Checkpoint Recovery Key: FLINK-28206 URL: https://issues.apache.org/jira/browse/FLINK-28206 Project: Flink Issue Type: Bug

Re: [DISCUSS] Maintain a Calcite repository for Flink to accelerate the development for Flink SQL features

Hi everyone, I've recently reached out to the Calcite community to see if we could somehow get something done with regards to the PR that Jing Zhang had opened a long time ago. In that thread, I also mentioned that we had a discussion in the Flink community on potentially forking Calcite. I would

Re: [DISCUSS] FLIP-221 Abstraction for lookup source cache and metric

Hi Qingsheng, I like the current design, thanks for your efforts! I have no objections at the moment. +1 to start the vote. Best regards, Alexander ср, 22 июн. 2022 г. в 15:59, Qingsheng Ren : > > Hi Jingsong, > > 1. Updated and thanks for the reminder! > > 2. We could do so for implementation

[DISCUSS] Support partition pruning for streaming reading

Hi devs, I want to start a discussion to find a way to support partition pruning for streaming reading. Now, Flink has supported the partition pruning, the implementation consists of *Source Ability*, *Logical Rule*, and the interface *SupportsPartitionPushDown*, but they all only take effect in

Re: Re: [ANNOUNCE] New Apache Flink Committers: Qingsheng Ren, Shengkai Fang

Congrats and welcome, Qingsheng and Shengkai! Best Regards, Yu On Wed, 22 Jun 2022 at 17:43, Jiangang Liu wrote: > Congratulations! > > Best, > Jiangang Liu > > Mason Chen 于2022年6月22日周三 00:37写道： > > > Awesome work Qingsheng and Shengkai! > > > > Best, > > Mason > > > > On Tue, Jun 21, 2022

Re: [DISCUSS] Release Kubernetes operator 1.0.1

+1 for the patch release. Thanks Gyula! On Wed, Jun 22, 2022 at 5:35 PM Márton Balassi wrote: > Hi team, > > +1 for having a 1.0.1 for the Kubernetes Operator. > > On Wed, Jun 22, 2022 at 4:23 PM Gyula Fóra wrote: > > > Hi Devs! > > > > How do you feel about releasing the 1.0.1 patch release

Re: [DISCUSS] Release Kubernetes operator 1.0.1

Hi team, +1 for having a 1.0.1 for the Kubernetes Operator. On Wed, Jun 22, 2022 at 4:23 PM Gyula Fóra wrote: > Hi Devs! > > How do you feel about releasing the 1.0.1 patch release for the Kubernetes > operator? > > We have fixed a few annoying issues that many people tend to hit. > > Given

[DISCUSS] Release Kubernetes operator 1.0.1

Hi Devs! How do you feel about releasing the 1.0.1 patch release for the Kubernetes operator? We have fixed a few annoying issues that many people tend to hit. Given that we are about halfway until the next minor release based on the proposed schedule I think we could prepare a 1.0.1 RC1 in the

[jira] [Created] (FLINK-28205) jdbc connector 定时调度 flush 存在内存泄漏 bug

michaelxiang created FLINK-28205: Summary: jdbc connector 定时调度 flush 存在内存泄漏 bug Key: FLINK-28205 URL: https://issues.apache.org/jira/browse/FLINK-28205 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28204) Deleting a FlinkDeployment results in an error on the pod

Matt Casters created FLINK-28204: Summary: Deleting a FlinkDeployment results in an error on the pod Key: FLINK-28204 URL: https://issues.apache.org/jira/browse/FLINK-28204 Project: Flink

[jira] [Created] (FLINK-28203) Mark all bundled dependencies as optional

Chesnay Schepler created FLINK-28203: Summary: Mark all bundled dependencies as optional Key: FLINK-28203 URL: https://issues.apache.org/jira/browse/FLINK-28203 Project: Flink Issue

[jira] [Created] (FLINK-28202) Generalize utils around shade-plugin

Chesnay Schepler created FLINK-28202: Summary: Generalize utils around shade-plugin Key: FLINK-28202 URL: https://issues.apache.org/jira/browse/FLINK-28202 Project: Flink Issue Type:

[jira] [Created] (FLINK-28201) Generalize utils around dependency-plugin

Chesnay Schepler created FLINK-28201: Summary: Generalize utils around dependency-plugin Key: FLINK-28201 URL: https://issues.apache.org/jira/browse/FLINK-28201 Project: Flink Issue

[VOTE] Release 1.15.1, release candidate #1

Hi everyone, Please review and vote on release candidate #1 for version 1.15.1, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1], * the

[jira] [Created] (FLINK-28200) Add Table Store Hive reader documentation

Jingsong Lee created FLINK-28200: Summary: Add Table Store Hive reader documentation Key: FLINK-28200 URL: https://issues.apache.org/jira/browse/FLINK-28200 Project: Flink Issue Type:

[jira] [Created] (FLINK-28199) Failures on YARNHighAvailabilityITCase.testClusterClientRetrieval and YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint

Martijn Visser created FLINK-28199: -- Summary: Failures on YARNHighAvailabilityITCase.testClusterClientRetrieval and YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint Key: FLINK-28199 URL:

[jira] [Created] (FLINK-28198) CassandraConnectorITCase#testRaiseCassandraRequestsTimeouts fails with timeout

Martijn Visser created FLINK-28198: -- Summary: CassandraConnectorITCase#testRaiseCassandraRequestsTimeouts fails with timeout Key: FLINK-28198 URL: https://issues.apache.org/jira/browse/FLINK-28198

[jira] [Created] (FLINK-28197) Flink didn't deletes the YARN application files when the submit is failed in application mode

zlzhang0122 created FLINK-28197: --- Summary: Flink didn't deletes the YARN application files when the submit is failed in application mode Key: FLINK-28197 URL: https://issues.apache.org/jira/browse/FLINK-28197

[jira] [Created] (FLINK-28196) Rename hadoop.version property

Chesnay Schepler created FLINK-28196: Summary: Rename hadoop.version property Key: FLINK-28196 URL: https://issues.apache.org/jira/browse/FLINK-28196 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28195) Annotate Python3.6 as deprecated in PyFlink 1.16

Huang Xingbo created FLINK-28195: Summary: Annotate Python3.6 as deprecated in PyFlink 1.16 Key: FLINK-28195 URL: https://issues.apache.org/jira/browse/FLINK-28195 Project: Flink Issue Type:

Re: Re: [ANNOUNCE] New Apache Flink Committers: Qingsheng Ren, Shengkai Fang

Congratulations! Best, Jiangang Liu Mason Chen 于2022年6月22日周三 00:37写道： > Awesome work Qingsheng and Shengkai! > > Best, > Mason > > On Tue, Jun 21, 2022 at 4:53 AM Zhipeng Zhang > wrote: > > > Congratulations, Qingsheng and ShengKai. > > > > Yang Wang 于2022年6月21日周二 19:43写道： > > > > >

[jira] [Created] (FLINK-28194) Remove workaround around avro sql jar

Chesnay Schepler created FLINK-28194: Summary: Remove workaround around avro sql jar Key: FLINK-28194 URL: https://issues.apache.org/jira/browse/FLINK-28194 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-221 Abstraction for lookup source cache and metric

Qingsheng Thanks for the update, Looks good to me! Best, Jingsong On Wed, Jun 22, 2022 at 5:00 PM Qingsheng Ren wrote: > > Hi Jingsong, > > 1. Updated and thanks for the reminder! > > 2. We could do so for implementation but as public interface I prefer not to > introduce another layer and

Re: [DISCUSS] FLIP-221 Abstraction for lookup source cache and metric

Hi Jingsong, 1. Updated and thanks for the reminder! 2. We could do so for implementation but as public interface I prefer not to introduce another layer and expose too much since this FLIP is already a huge one with bunch of classes and interfaces. Best, Qingsheng > On Jun 22, 2022, at

Re: [DISCUSS] Flink Kubernetes Operator release cadence proposal

Thanks for the proposal, Matyas. +1 for 2 month release cycles with the breakdown Gyula suggested. @Yang: we could start tagging features with 1.1 / 1.2 version then, good call. On Wed, Jun 22, 2022 at 4:58 AM Yang Wang wrote: > +1 for 2 month release cycles. > > Since we have promised the

[jira] [Created] (FLINK-28193) Enable to identify whether a job vertex contains source/sink operators

Zhu Zhu created FLINK-28193: --- Summary: Enable to identify whether a job vertex contains source/sink operators Key: FLINK-28193 URL: https://issues.apache.org/jira/browse/FLINK-28193 Project: Flink

Re: Re: [DISCUSS] FLIP-240: Introduce "ANALYZE TABLE" Syntax

sounds good to me. Thanks! Best regards, Jing On Fri, Jun 17, 2022 at 5:37 AM godfrey he wrote: > Hi, Jing. > > Thanks for the feedback. > > >When will the converted SELECT statement of the ANALYZE TABLE be > > submitted? right after the CREATE TABLE? > The SELECT job will be submitted only

[DISCUSS] FLIP-244: Support IterativeCondition with Accumulator in CEP Pattern

Hi everyone, IterativeCondition defines a user-defined condition that decides if an element should be accepted in the pattern or not. The condition iterates over the previously accepted elements in the pattern and decides to accept a new element or not based on some statistic over elements. In

[jira] [Created] (FLINK-28192) RescaleBucketITCase is not stable

Jane Chan created FLINK-28192: - Summary: RescaleBucketITCase is not stable Key: FLINK-28192 URL: https://issues.apache.org/jira/browse/FLINK-28192 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] Apache Flink 1.14.5 released

Thank you Xingbo and our community for creating this release! Op wo 22 jun. 2022 om 05:51 schreef Xingbo Huang : > The Apache Flink community is very happy to announce the release of Apache > Flink 1.14.5, which is the fourth bugfix release for the Apache Flink 1.14 > series. > > Apache Flink® is