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
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:
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
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
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
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
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
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
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
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
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
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
12 matches
Mail list logo