[jira] [Created] (FLINK-29104) Check mutability of CoreOptions

Jane Chan created FLINK-29104: - Summary: Check mutability of CoreOptions Key: FLINK-29104 URL: https://issues.apache.org/jira/browse/FLINK-29104 Project: Flink Issue Type: Improvement C

[jira] [Created] (FLINK-29103) FileNotFoundException: No such file or directory: s3://

hehetown created FLINK-29103: Summary: FileNotFoundException: No such file or directory: s3:// Key: FLINK-29103 URL: https://issues.apache.org/jira/browse/FLINK-29103 Project: Flink Issue Type: B

Re: [VOTE] Apache Flink Table Store 0.2.0, release candidate #3

+1 (binding) - Checked release notes: *OK* - Checked sums and signatures: *OK* - Checked the jars in the staging repo: *OK* - Checked source distribution doesn't include binaries: *OK* - Maven clean install from source: *OK* - Checked version consistency in pom files: *OK* - Went through the quick

Re: [ANNOUNCE] Apache Flink 1.15.2 released

Thanks Danny for driving this release Best, Xingbo Jing Ge 于2022年8月25日周四 05:50写道： > Thanks Danny for your effort! > > Best regards, > Jing > > On Wed, Aug 24, 2022 at 11:43 PM Danny Cranmer > wrote: > >> The Apache Flink community is very happy to announce the release of >> Apache Flink 1.15.2

[jira] [Created] (FLINK-29102) ChangelogLocalRecoveryITCase.testRestartTM failed with AssertionFailedError

Xingbo Huang created FLINK-29102: Summary: ChangelogLocalRecoveryITCase.testRestartTM failed with AssertionFailedError Key: FLINK-29102 URL: https://issues.apache.org/jira/browse/FLINK-29102 Project:

[jira] [Created] (FLINK-29101) PipelinedRegionSchedulingStrategy benchmark shows performance degradation

Weijie Guo created FLINK-29101: -- Summary: PipelinedRegionSchedulingStrategy benchmark shows performance degradation Key: FLINK-29101 URL: https://issues.apache.org/jira/browse/FLINK-29101 Project: Flink

RE: [DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api

+1, Lgtm, this proposal may helps me to manage the job more conveniently On 2022/08/15 10:06:18 zhengyu chen wrote: > Hi all, > > > We would like to start a discussion thread on FLIP-256 Support Job Dynamic > Parameter With Flink Rest Api >

Re: Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang

Congratulations, Junhan! Best Regards, Yu On Thu, 25 Aug 2022 at 10:07, Yun Gao wrote: > Congratulations Junhan! > > > Best, > Yun Gao > > > -- > Sender:Yangze Guo > Date:2022/08/25 10:04:14 > Recipient:dev > Cc: > Theme:Re: [ANNO

Re: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang

Congratulations, Lijie! Best Regards, Yu On Thu, 25 Aug 2022 at 10:07, Yun Gao wrote: > Congratulations Lijie! > > Best, > Yun Gao > > > -- > Sender:Yangze Guo > Date:2022/08/25 10:04:35 > Recipient:dev > Cc:Lijie Wang > Theme:Re:

Re: Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang

Congratulations Junhan! Best, Yun Gao -- Sender:Yangze Guo Date:2022/08/25 10:04:14 Recipient:dev Cc: Theme:Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang Congrats! Jark Wu 于 2022年8月24日周三 下午3:46写道： > Congrats Junhan! >

Re: Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang

Congratulations Lijie! Best, Yun Gao -- Sender:Yangze Guo Date:2022/08/25 10:04:35 Recipient:dev Cc:Lijie Wang Theme:Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang Congrats! Jark Wu 于 2022年8月24日周三 下午3:47写道： > Congrats Li

Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang

Congrats! Jark Wu 于 2022年8月24日周三 下午3:47写道： > Congrats Lijie! > > Best, > Jark > > On Wed, 24 Aug 2022 at 15:06, Qingsheng Ren wrote: > > > Congratulations Lijie! > > > > Best regards, > > Qingsheng > > > > > On Aug 22, 2022, at 16:29, Yang Wang wrote: > > > > > > Congrats Lijie! > > > > > > Be

Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang

Congrats! Jark Wu 于 2022年8月24日周三 下午3:46写道： > Congrats Junhan! > > Best, > Jark > > On Wed, 24 Aug 2022 at 15:05, Qingsheng Ren wrote: > > > Congratulations Junhan! > > > > Best regards, > > Qingsheng > > > > > On Aug 22, 2022, at 16:30, Yang Wang wrote: > > > > > > Congrats Junhan! > > > > > >

[jira] [Created] (FLINK-29100) Deployment with last-state upgrade mode stuck after initial error

Thomas Weise created FLINK-29100: Summary: Deployment with last-state upgrade mode stuck after initial error Key: FLINK-29100 URL: https://issues.apache.org/jira/browse/FLINK-29100 Project: Flink

Re: [DISCUSS] ARM support for Flink

Hi Flink, Any idea about this? ;-) bo zhaobo 于2022年8月23日周二 19:28写道： > Hi Flinkers, > > In 2019, we raised an discussion in Flink about "ARM support for > Flink"[1]. And we got so many helps and supports from Flink community about > introducing a ARM CI system into Flink community, which is named

Re: [ANNOUNCE] Apache Flink 1.15.2 released

Thanks Danny for your effort! Best regards, Jing On Wed, Aug 24, 2022 at 11:43 PM Danny Cranmer wrote: > The Apache Flink community is very happy to announce the release of Apache > Flink 1.15.2, which is the second bugfix release for the Apache Flink 1.15 > series. > > Apache Flink® is an open

[ANNOUNCE] Apache Flink 1.15.2 released

The Apache Flink community is very happy to announce the release of Apache Flink 1.15.2, which is the second bugfix release for the Apache Flink 1.15 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming

[jira] [Created] (FLINK-29099) Deadlock for Single Subtask in Kinesis Consumer

seth saperstein created FLINK-29099: --- Summary: Deadlock for Single Subtask in Kinesis Consumer Key: FLINK-29099 URL: https://issues.apache.org/jira/browse/FLINK-29099 Project: Flink Issue T

[jira] [Created] (FLINK-29098) StoreWriteOperator#prepareCommit should let logSinkFunction flush first before fetching offset

Jane Chan created FLINK-29098: - Summary: StoreWriteOperator#prepareCommit should let logSinkFunction flush first before fetching offset Key: FLINK-29098 URL: https://issues.apache.org/jira/browse/FLINK-29098

[jira] [Created] (FLINK-29097) Moving json se/deserializers from sql-gateway-api to sql-gateway

Wencong Liu created FLINK-29097: --- Summary: Moving json se/deserializers from sql-gateway-api to sql-gateway Key: FLINK-29097 URL: https://issues.apache.org/jira/browse/FLINK-29097 Project: Flink

[jira] [Created] (FLINK-29096) json_value when the path has blank, the result is not right

jackylau created FLINK-29096: Summary: json_value when the path has blank, the result is not right Key: FLINK-29096 URL: https://issues.apache.org/jira/browse/FLINK-29096 Project: Flink Issue Ty

Re: [VOTE] Apache Flink Table Store 0.2.0, release candidate #3

Hi all! +1 for the release (non-binding). I've verified the jar with SQL client and listed the check items as follows: * Compiled the sources and built the source distribution - PASSED * Ran through Quick Start Guide - PASSED * Checked Spark 2.3.4&3.3.0 reader and catalog with table store jar -

[jira] [Created] (FLINK-29095) logging state file deletion

Jing Ge created FLINK-29095: --- Summary: logging state file deletion Key: FLINK-29095 URL: https://issues.apache.org/jira/browse/FLINK-29095 Project: Flink Issue Type: New Feature Component

[jira] [Created] (FLINK-29094) Cannot stop Python job with savepoint when using Kafka Consumer

Bartosz Mikulski created FLINK-29094: Summary: Cannot stop Python job with savepoint when using Kafka Consumer Key: FLINK-29094 URL: https://issues.apache.org/jira/browse/FLINK-29094 Project: Flin

Re: [upsert-kafka][SQL] Why Upsert-Kafka SQL connector is a different connector from the Kafka SQL Connector

Thanks~ Will take a look. Cheers, Yufei On Wed, Aug 24, 2022 at 3:45 PM Jark Wu wrote: > There was a long discussion about this. You can read the thread[1]. > > Best, > Jark > > [1]: https://lists.apache.org/thread/sr6on0cq52ns4y3zh6j0x899by80n5zw > > On Wed, 24 Aug 2022 at 13:20, Yufei Zhang

Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang

Congrats Lijie! Best, Jark On Wed, 24 Aug 2022 at 15:06, Qingsheng Ren wrote: > Congratulations Lijie! > > Best regards, > Qingsheng > > > On Aug 22, 2022, at 16:29, Yang Wang wrote: > > > > Congrats Lijie! > > > > Best, > > Yang > > > > Matthias Pohl 于2022年8月22日周一 15:34写道： > > > >> Congrats

[VOTE] Apache Flink Table Store 0.2.0, release candidate #3

Hi everyone, Please review and vote on the release candidate #3 for the version 0.2.0 of Apache Flink Table Store, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) **Release Overview** As an overview, the release consists of the follo

Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang

Congrats Junhan! Best, Jark On Wed, 24 Aug 2022 at 15:05, Qingsheng Ren wrote: > Congratulations Junhan! > > Best regards, > Qingsheng > > > On Aug 22, 2022, at 16:30, Yang Wang wrote: > > > > Congrats Junhan! > > > > > > Best, > > Yang > > > > Matthias Pohl 于2022年8月22日周一 15:35写道： > > > >> Co

Re: [upsert-kafka][SQL] Why Upsert-Kafka SQL connector is a different connector from the Kafka SQL Connector

There was a long discussion about this. You can read the thread[1]. Best, Jark [1]: https://lists.apache.org/thread/sr6on0cq52ns4y3zh6j0x899by80n5zw On Wed, 24 Aug 2022 at 13:20, Yufei Zhang wrote: > Hi all, > > I noticed there is a Upsert-Kafka SQL Connector[1] and the Kafka SQL > Connector[2

[jira] [Created] (FLINK-29093) LookupJoinITCase failed with InternalCompilerException

Xingbo Huang created FLINK-29093: Summary: LookupJoinITCase failed with InternalCompilerException Key: FLINK-29093 URL: https://issues.apache.org/jira/browse/FLINK-29093 Project: Flink Issue

[jira] [Created] (FLINK-29092) HadoopPathBasedPartFileWriterTest.testWriteFile failed with AssertionError

Xingbo Huang created FLINK-29092: Summary: HadoopPathBasedPartFileWriterTest.testWriteFile failed with AssertionError Key: FLINK-29092 URL: https://issues.apache.org/jira/browse/FLINK-29092 Project: F

Re: [VOTE] Apache Flink Table Store 0.2.0, release candidate #2

Hi all! -1 for this release candidate as Hive catalog and Hive connector fail to support Hive CDH. See https://issues.apache.org/jira/browse/FLINK-29071 for more detail. Yu Li 于2022年8月23日周二 17:31写道： > +1 (binding) > > - Checked release notes: *Action Required* > - Minor: there're still 25 op

Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang

Congratulations Lijie! Best regards, Qingsheng > On Aug 22, 2022, at 16:29, Yang Wang wrote: > > Congrats Lijie! > > Best, > Yang > > Matthias Pohl 于2022年8月22日周一 15:34写道： > >> Congrats & welcome to the team! :-) >> >> Matthias >> >> On Sun, Aug 21, 2022 at 5:41 AM Yuan Mei wrote: >> >>>

Re: [ANNOUNCE] New Apache Flink Committer - Junhan Yang

Congratulations Junhan! Best regards, Qingsheng > On Aug 22, 2022, at 16:30, Yang Wang wrote: > > Congrats Junhan! > > > Best, > Yang > > Matthias Pohl 于2022年8月22日周一 15:35写道： > >> Congratulations & welcome! :-) >> >> Matthias >> >> On Sun, Aug 21, 2022 at 5:42 AM Yuan Mei wrote: >> >>>