[jira] [Created] (FLINK-24617) Support partition keys through metadata

Francesco Guardiani created FLINK-24617: --- Summary: Support partition keys through metadata Key: FLINK-24617 URL: https://issues.apache.org/jira/browse/FLINK-24617 Project: Flink Issue T

[jira] [Created] (FLINK-24618) FlinkChillPackageRegistrar and PriorityQueueSerializer are located in wrong package

Matthias created FLINK-24618: Summary: FlinkChillPackageRegistrar and PriorityQueueSerializer are located in wrong package Key: FLINK-24618 URL: https://issues.apache.org/jira/browse/FLINK-24618 Project:

Re: [ANNOUNCE] Apache Flink 1.13.3 released

Thanks for Chesnay & Martijn and everyone who made this release happen. Best Yun Tang From: JING ZHANG Sent: Friday, October 22, 2021 10:17 To: dev Cc: Martijn Visser ; Jingsong Li ; Chesnay Schepler ; user Subject: Re: [ANNOUNCE] Apache Flink 1.13.3 released

[jira] [Created] (FLINK-24619) rabbit not support " at least once "

szd created FLINK-24619: --- Summary: rabbit not support " at least once " Key: FLINK-24619 URL: https://issues.apache.org/jira/browse/FLINK-24619 Project: Flink Issue Type: Bug Components: Conn

Re: [ANNOUNCE] Apache Flink 1.13.3 released

Thank Chesnay, Martijn, and everyone involved! Best, Yangze Guo On Fri, Oct 22, 2021 at 4:25 PM Yun Tang wrote: > > Thanks for Chesnay & Martijn and everyone who made this release happen. > > Best > Yun Tang > > From: JING ZHANG > Sent: Friday, October 22, 2021

[jira] [Created] (FLINK-24620) Add partition discovery for kafka sink when `sink.partitioner`= 'fix'

hehuiyuan created FLINK-24620: - Summary: Add partition discovery for kafka sink when `sink.partitioner`= 'fix' Key: FLINK-24620 URL: https://issues.apache.org/jira/browse/FLINK-24620 Project: Flink

[jira] [Created] (FLINK-24621) JobManager fails to recover 1.13.1 checkpoint due to InflightDataRescalingDescriptor

Chesnay Schepler created FLINK-24621: Summary: JobManager fails to recover 1.13.1 checkpoint due to InflightDataRescalingDescriptor Key: FLINK-24621 URL: https://issues.apache.org/jira/browse/FLINK-24621

Re: Disable usage of TumblingEventTimeWindows when EventTime is disabled?

Hi Dario, I think adding a sanity check that checks whether the user uses some event time constructs and prints a warning if WatermarkStrategy.noWatermarks() is set, could be a good improvement. It might even be ok to fail to make this misconfiguration explicit. Hence, I think it is a good idea to

Re: [ANNOUNCE] Apache Flink 1.13.3 released

Thanks Chesnay and Martijn for managing this release and to everyone who contributed to it. Cheers, Till On Fri, Oct 22, 2021 at 11:04 AM Yangze Guo wrote: > Thank Chesnay, Martijn, and everyone involved! > > Best, > Yangze Guo > > On Fri, Oct 22, 2021 at 4:25 PM Yun Tang wrote: > > > > Thanks

[jira] [Created] (FLINK-24622) Unified sources do not close scheduled threads from SplitEnumeratorContext#callAsync()

Mason Chen created FLINK-24622: -- Summary: Unified sources do not close scheduled threads from SplitEnumeratorContext#callAsync() Key: FLINK-24622 URL: https://issues.apache.org/jira/browse/FLINK-24622 Pr

Re: [VOTE] FLIP-176: Unified Iteration to Support Algorithms (Flink ML)

Thanks for creating this FLIP. +1 (binding) Cheers, Till On Fri, Oct 22, 2021 at 6:29 AM Guowei Ma wrote: > +1 (binding) > > Best, > Guowei > > > On Thu, Oct 21, 2021 at 3:58 PM Yun Gao > wrote: > > > > > Hi all, > > > > We would like to start the vote for FLIP-176: Unified Iteration to > Su

Shading in flink-table-blink and upgrade compatibility issue

Hi, As part of upgrading to Flink 1.13.3 from 1.13.2 we run into the following problem with KafkaSource (Flink distribution is 1.13.2 and the application was built with 1.13.3): java.lang.NoSuchMethodError: 'void org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager.(or