[jira] [Created] (FLINK-23152) Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

liu zhuang created FLINK-23152: -- Summary: Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]} Key: FLINK-23152 URL:

回复：回复：[DISCUSS] [FLINK-23122] Provide the Dynamic register converter

@Timo Walther Thanks great reply. 1, TIMESTAMP_WITH_TIME_ZONE issue: https://issues.apache.org/jira/browse/FLINK-23145 will track. 2, Unsupported types of other systems: I basic agree that provide modules to load specific types on demand. But to my concern : 2.1 the conversion for different

[jira] [Created] (FLINK-23151) KinesisTableApiITCase.testTableApiSourceAndSink fails on azure

Xintong Song created FLINK-23151: Summary: KinesisTableApiITCase.testTableApiSourceAndSink fails on azure Key: FLINK-23151 URL: https://issues.apache.org/jira/browse/FLINK-23151 Project: Flink

Re: [DISCUSS] Do not merge PRs with "unrelated" test failures.

Creating a blocker issue for the manually disabled tests sounds good to me. Minor: I'm still a bit worried about the commits merged before we fix the unstable tests can also break those tests. Instead of letting the assigners keep a look at all potentially related commits, they can maintain a

Re: [VOTE] FLIP-171: Async Sink

A common base for implementing sink is really helpful. +1 (binding) Thanks liujiangang Danny Cranmer 于2021年6月24日周四 下午7:10写道： > Looking forward to simplifying adding new destination sinks. > > +1 (binding). > > Thanks > > On Thu, 24 Jun 2021, 10:46 Arvid Heise, wrote: > > > Thanks for

[jira] [Created] (FLINK-23150) Clean up the old implementation of code splitting

Caizhi Weng created FLINK-23150: --- Summary: Clean up the old implementation of code splitting Key: FLINK-23150 URL: https://issues.apache.org/jira/browse/FLINK-23150 Project: Flink Issue Type:

[jira] [Created] (FLINK-23149) Introduce Java code splitter for code generation

Caizhi Weng created FLINK-23149: --- Summary: Introduce Java code splitter for code generation Key: FLINK-23149 URL: https://issues.apache.org/jira/browse/FLINK-23149 Project: Flink Issue Type:

[jira] [Created] (FLINK-23148) flink-mesos does not build with scala 2.12

Xintong Song created FLINK-23148: Summary: flink-mesos does not build with scala 2.12 Key: FLINK-23148 URL: https://issues.apache.org/jira/browse/FLINK-23148 Project: Flink Issue Type: Bug

[RESULT][VOTE] FLIP-169: DataStream API for Fine-Grained Resource Requirements

Hi all, The voting time of FLIP-169[1] has passed. I'm closing the vote now. There were six +1 votes, 3 of which are binding: - Xintong Song (binding) - Arvid Heise (binding) - Zhu Zhu (binding) - Yang Wang (non-binding) - Jiangang Liu (non-binding) - Jing Zhang (non-binding) There were no -1

[jira] [Created] (FLINK-23147) ThreadPools can be poisoned by context class loaders

Chesnay Schepler created FLINK-23147: Summary: ThreadPools can be poisoned by context class loaders Key: FLINK-23147 URL: https://issues.apache.org/jira/browse/FLINK-23147 Project: Flink

[jira] [Created] (FLINK-23146) Data cannot be consumed when upsert Kafka is used as the source

JasonLee created FLINK-23146: Summary: Data cannot be consumed when upsert Kafka is used as the source Key: FLINK-23146 URL: https://issues.apache.org/jira/browse/FLINK-23146 Project: Flink

Re: [ANNOUNCE] New PMC member: Arvid Heise

Congratulations Arvid ! On Thu, Jun 24, 2021 at 8:03 PM Etienne Chauchot wrote: > Congratulations Arvid ! > > Etienne > > On 24/06/2021 12:04, Lijie Wang wrote: > > Congratulations! > > > > Igal Shilman 于2021年6月24日周四 下午5:46写道： > > > >> Congratulations Arvid! > >> Super well deserved! > >> > >>

Re: [DISCUSS] Releasing Flink 1.12.5

Thanks for volunteering as our release manager, Jingsong. From my perspective, we are good to go for the 1.12.5 release. Cheers, Till On Thu, Jun 24, 2021 at 11:53 AM Jingsong Li wrote: > Dear devs, > > As discussed in [1], I would volunteer as the release manager for 1.12.5 > and kick off the

Re: [DISCUSS] Do not merge PRs with "unrelated" test failures.

I like the idea of creating a blocker issue for a disabled test. This will force us to resolve it in a timely manner and it won't fall through the cracks. Cheers, Till On Thu, Jun 24, 2021 at 8:06 AM Jingsong Li wrote: > +1 to Xintong's proposal > > I also have some concerns about unstable

[jira] [Created] (FLINK-23145) TIMESTAMP_WITH_TIME_ZONE support

lqjacklee created FLINK-23145: - Summary: TIMESTAMP_WITH_TIME_ZONE support Key: FLINK-23145 URL: https://issues.apache.org/jira/browse/FLINK-23145 Project: Flink Issue Type: Improvement

Re: 回复：[DISCUSS] [FLINK-23122] Provide the Dynamic register converter

Hi Jack, thanks for sharing your proposal with us. I totally understand the issues that you are trying to solve. Having a more flexible type support in the connectors is definitely a problem that we would like to address in the mid term. It is already considered in on our internal roadmap

[jira] [Created] (FLINK-23144) Add percentiles to checkpoint stats

Roman Khachatryan created FLINK-23144: - Summary: Add percentiles to checkpoint stats Key: FLINK-23144 URL: https://issues.apache.org/jira/browse/FLINK-23144 Project: Flink Issue Type:

回复：[DISCUSS] [FLINK-23122] Provide the Dynamic register converter

@Jark Wuthanks reply. However Several case I want to cover: 1, Unknown types CITEXT: Flink SQL cannot exexute "CREATE TABLE string_table (pk SERIAL, vc VARCHAR(2), vcv CHARACTER VARYING(2), ch CHARACTER(4), c CHAR(3), t TEXT, b BYTEA, bnn BYTEA NOT NULL, ct CITEXT, PRIMARY KEY(pk));". this

Re: [ANNOUNCE] New PMC member: Arvid Heise

Congratulations Arvid ! Etienne On 24/06/2021 12:04, Lijie Wang wrote: Congratulations! Igal Shilman 于2021年6月24日周四 下午5:46写道： Congratulations Arvid! Super well deserved! On Thu, Jun 24, 2021 at 11:33 AM 刘建刚 wrote: Congratulations Best liujiangang Matthias Pohl 于2021年6月23日周三

[RESULT][VOTE] FLIP-129 Register sources/sinks in Table API

Hi everyone, The vote for FLIP-129 has now been closed. We have five approving votes, four of which are binding: * Timo Walther (binding) * Jark Wu (binding) * Jingsong Li (binding) * Jing Zhang (binding) * Leonard Xu There are no disapproving votes. Thanks everyone for voting! Regards Ingo

[jira] [Created] (FLINK-23143) Support state migration

Roman Khachatryan created FLINK-23143: - Summary: Support state migration Key: FLINK-23143 URL: https://issues.apache.org/jira/browse/FLINK-23143 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23142) UpdatableTopNFunction output wrong order in the same unique key

Jingsong Lee created FLINK-23142: Summary: UpdatableTopNFunction output wrong order in the same unique key Key: FLINK-23142 URL: https://issues.apache.org/jira/browse/FLINK-23142 Project: Flink

Re: [DISCUSS] Drop Mesos in 1.14

Hi, +1 on dropping Mesos support to clear dependencies in the flink-runtime module: - I tend to think as Seth and Israel and see a bit of a decline of the use of Mesos: as an example of that, AFAICT, Amazon EMR and Amazon EKS provide Yarn and Kubernates support but no Mesos. I did not know

Re: [VOTE] FLIP-171: Async Sink

Looking forward to simplifying adding new destination sinks. +1 (binding). Thanks On Thu, 24 Jun 2021, 10:46 Arvid Heise, wrote: > Thanks for preparing the FLIP. +1 (binding) from my side. > > On Tue, Jun 22, 2021 at 2:28 PM Hausmann, Steffen > > wrote: > > > Hi there, > > > > After the

Re: Change in accumutors semantics with jobClient

My pleasure ! Thanks for pointing out the release notes. Cheers, Etienne On 23/06/2021 14:00, Till Rohrmann wrote: Yes, it should be part of the release notes where this change was introduced. I'll take a look at your PR. Thanks a lot Etienne. Cheers, Till On Wed, Jun 23, 2021 at 12:29 PM

Re: Re: [ANNOUNCE] New PMC member: Arvid Heise

Congratulations! Igal Shilman 于2021年6月24日周四 下午5:46写道： > Congratulations Arvid! > Super well deserved! > > > On Thu, Jun 24, 2021 at 11:33 AM 刘建刚 wrote: > > > Congratulations > > > > Best > > liujiangang > > > > Matthias Pohl 于2021年6月23日周三 下午2:11写道： > > > > > Congratulations, Arvid! :-) > > >

[DISCUSS] Releasing Flink 1.12.5

Dear devs, As discussed in [1], I would volunteer as the release manager for 1.12.5 and kick off the release process on next Wednesday (June 30th). I went through 1.12.5 issues [2], all blockers have been fixed. If you think there is any blocker in 1.12.5, please reply to this thread at any

[jira] [Created] (FLINK-23141) Support KafkaSerializationSchema in Kafka connector for Python DataStream API

Dian Fu created FLINK-23141: --- Summary: Support KafkaSerializationSchema in Kafka connector for Python DataStream API Key: FLINK-23141 URL: https://issues.apache.org/jira/browse/FLINK-23141 Project: Flink

Re: Re: [ANNOUNCE] New PMC member: Arvid Heise

Congratulations Arvid! Super well deserved! On Thu, Jun 24, 2021 at 11:33 AM 刘建刚 wrote: > Congratulations > > Best > liujiangang > > Matthias Pohl 于2021年6月23日周三 下午2:11写道： > > > Congratulations, Arvid! :-) > > > > On Thu, Jun 17, 2021 at 9:02 AM Arvid Heise wrote: > > > > > Thank you for your

Re: [VOTE] FLIP-171: Async Sink

Thanks for preparing the FLIP. +1 (binding) from my side. On Tue, Jun 22, 2021 at 2:28 PM Hausmann, Steffen wrote: > Hi there, > > After the discussion in [1], I’d like to open a voting thread for FLIP-171 > [2], which proposes a base implementation for sinks that support async > requests. > >

Re: Re: [ANNOUNCE] New PMC member: Arvid Heise

Congratulations Best liujiangang Matthias Pohl 于2021年6月23日周三 下午2:11写道： > Congratulations, Arvid! :-) > > On Thu, Jun 17, 2021 at 9:02 AM Arvid Heise wrote: > > > Thank you for your trust and support. > > > > Arvid > > > > On Thu, Jun 17, 2021 at 8:39 AM Roman Khachatryan > > wrote: > > > > >

Re: [DISCUSS] Releasing Flink 1.11.4, 1.12.5, 1.13.2

Hi all, As discussed offline, I will act as the release manager for 1.13.2. And I have went through all blocker tickets to see all resolved. (FLINK-23025 has resolved the part of release-1.13 and no longer block releasing 1.13.2). If you want

[jira] [Created] (FLINK-23140) Invalid link in Data Sources documentation

Dawid Wysakowicz created FLINK-23140: Summary: Invalid link in Data Sources documentation Key: FLINK-23140 URL: https://issues.apache.org/jira/browse/FLINK-23140 Project: Flink Issue

[jira] [Created] (FLINK-23138) Raise an exception if types other than PickledBytesTypeInfo are specified for state descriptor

Dian Fu created FLINK-23138: --- Summary: Raise an exception if types other than PickledBytesTypeInfo are specified for state descriptor Key: FLINK-23138 URL: https://issues.apache.org/jira/browse/FLINK-23138

[jira] [Created] (FLINK-23139) State ownership: track and discard state (materialized and non-materialized)

Roman Khachatryan created FLINK-23139: - Summary: State ownership: track and discard state (materialized and non-materialized) Key: FLINK-23139 URL: https://issues.apache.org/jira/browse/FLINK-23139

[jira] [Created] (FLINK-23137) State ownership: disable discarding state of ChangelogStateBackendHandle on JM

Roman Khachatryan created FLINK-23137: - Summary: State ownership: disable discarding state of ChangelogStateBackendHandle on JM Key: FLINK-23137 URL: https://issues.apache.org/jira/browse/FLINK-23137

[jira] [Created] (FLINK-23136) Make `addSource` method with specific boundedness in `StreamExecutionEnvironment` public

Shuo Cheng created FLINK-23136: -- Summary: Make `addSource` method with specific boundedness in `StreamExecutionEnvironment` public Key: FLINK-23136 URL: https://issues.apache.org/jira/browse/FLINK-23136

[jira] [Created] (FLINK-23135) Error while applying rule AggregateReduceGroupingRule

zhengjiewen created FLINK-23135: --- Summary: Error while applying rule AggregateReduceGroupingRule Key: FLINK-23135 URL: https://issues.apache.org/jira/browse/FLINK-23135 Project: Flink Issue

[jira] [Created] (FLINK-23134) add URL decode for metric rest

tartarus created FLINK-23134: Summary: add URL decode for metric rest Key: FLINK-23134 URL: https://issues.apache.org/jira/browse/FLINK-23134 Project: Flink Issue Type: Bug Components:

Re: [VOTE] FLIP-169: DataStream API for Fine-Grained Resource Requirements

+1 (binding) Thanks Yangze for driving the issue. Best regards, JING ZHANG Yang Wang 于2021年6月24日周四 下午1:51写道： > +1 (non-binding) > > Best, > Yang > > 刘建刚 于2021年6月24日周四 下午12:17写道： > > > +1 (binding) > > > > Thanks > > liujiangang > > > > Zhu Zhu 于2021年6月24日周四 上午11:38写道： > > > > > +1

[jira] [Created] (FLINK-23133) The dependencies are not handled properly when mixing use of Python Table API and Python DataStream API

Dian Fu created FLINK-23133: --- Summary: The dependencies are not handled properly when mixing use of Python Table API and Python DataStream API Key: FLINK-23133 URL: https://issues.apache.org/jira/browse/FLINK-23133

Re: [DISCUSS] Do not merge PRs with "unrelated" test failures.

+1 to Xintong's proposal I also have some concerns about unstable cases. I think unstable cases can be divided into these types: - Force majeure: For example, network timeout, sudden environmental collapse, they are accidental and can always be solved by triggering azure again. Committers