Rui Fan created FLINK-36129:
---
Summary: Autoscaler is compatible with Flink 1.20
Key: FLINK-36129
URL: https://issues.apache.org/jira/browse/FLINK-36129
Project: Flink
Issue Type: Improvement
Hi Daniel，
>
> There's no way to convert a different changelog stream to an insertonly
> stream so I'm pushing this upstream to the connector.
I wonder whether you just want the insert type changelog and ignore other
kinds of changelog, or just want to read all kinds of changelog as insert
in fli
Hi Qingsheng,
After some testing I’ve noticed that current default schema evolve behavior
“EVOLVE”. In such configuration, jobs that crashed without successfully
persisted schema might not be able to restore. FLINK-36128[1] suggests using
“LENIENT” mode as default, which evolves schema by keepi
+1 (binding)
Best,
Lincoln Lee
Feng Jin 于2024年8月22日周四 09:44写道：
> +1 (non-binding)
>
> Best,
> Feng
>
>
> On Thu, Aug 22, 2024 at 9:42 AM Ron Liu wrote:
>
> > +1(binding)
> >
> > Best,
> > Ron
> >
> > Zakelly Lan 于2024年8月21日周三 11:16写道：
> >
> > > +1 (binding)
> > >
> > > Best,
> > > Zakelly
>
+1 (non-binding)
Best,
Feng
On Thu, Aug 22, 2024 at 9:42 AM Ron Liu wrote:
> +1(binding)
>
> Best,
> Ron
>
> Zakelly Lan 于2024年8月21日周三 11:16写道：
>
> > +1 (binding)
> >
> > Best,
> > Zakelly
> >
> > On Wed, Aug 21, 2024 at 10:33 AM Xuyang wrote:
> >
> > > Hi, everyone.
> > >
> > > I would like
+1(binding)
Best,
Ron
Zakelly Lan 于2024年8月21日周三 11:16写道：
> +1 (binding)
>
> Best,
> Zakelly
>
> On Wed, Aug 21, 2024 at 10:33 AM Xuyang wrote:
>
> > Hi, everyone.
> >
> > I would like to start a vote on FLIP-473: Introduce New SQL Operators
> Based
> >
> > on Asynchronous State APIs [1]. The d
yux created FLINK-36128:
---
Summary: Promote LENIENT mode as the default schema evolution
behavior
Key: FLINK-36128
URL: https://issues.apache.org/jira/browse/FLINK-36128
Project: Flink
Issue Type: Impr
Hey,
I'd like to consume the postgres-cdc connector with an insert-only
changelog. I'm uninterested in any retraction messages since our use case
doesn't require it, and we can greatly benefit from the flink operations
that insert-only changelog provides. E.g. I want to do a tumble window
aggregat
Thank you for driving this!
+1 (non-binding)
Best,
Aleksandr
On Wed, 21 Aug 2024 at 15:21, Ahmed Hamdy wrote:
> Thanks for driving Abhisagar,
> +1 (non-binding)
>
> Best Regards
> Ahmed Hamdy
>
>
> On Wed, 21 Aug 2024 at 09:11, Abhisagar Khatri <
> khatri.abhisaga...@gmail.com>
> wrote:
>
> > H
Yu Chen created FLINK-36127:
---
Summary: Support sorting watermark on flink web
Key: FLINK-36127
URL: https://issues.apache.org/jira/browse/FLINK-36127
Project: Flink
Issue Type: Improvement
Thanks for driving Abhisagar,
+1 (non-binding)
Best Regards
Ahmed Hamdy
On Wed, 21 Aug 2024 at 09:11, Abhisagar Khatri
wrote:
> Hi Flink Devs,
>
> Thank you for all the feedback about FLIP-477: Amazon SQS Source Connector
> [1]. The discussion thread can be found here [2].
>
> The vote will be
Sergey Nuyanzin created FLINK-36126:
---
Summary: Qualification of current catalog and current database
should happen during execution, not parsing
Key: FLINK-36126
URL: https://issues.apache.org/jira/browse/FLINK-
Burak Ozakinci created FLINK-36125:
--
Summary: File not found exception on restoring state handles with
file merging
Key: FLINK-36125
URL: https://issues.apache.org/jira/browse/FLINK-36125
Project: Fl
Gabor Somogyi created FLINK-36124:
-
Summary: S3RecoverableFsDataOutputStream.sync closes the stream
and further write operation throw exception
Key: FLINK-36124
URL: https://issues.apache.org/jira/browse/FLINK-361
Dylan He created FLINK-36123:
Summary: Add PERCENTILE function
Key: FLINK-36123
URL: https://issues.apache.org/jira/browse/FLINK-36123
Project: Flink
Issue Type: Sub-task
Components: Ta
xuyang created FLINK-36122:
--
Summary: Redundant cast in outer layer when comparing Row Types
for equality
Key: FLINK-36122
URL: https://issues.apache.org/jira/browse/FLINK-36122
Project: Flink
Issu
Hi everyone,
I'm happy to announce that FLIP-455 [1] has been accepted [2]. There were 7
votes in favour, 4 of them are binding:
Yanfei Lei (binding)
Yuepeng Pan
Xuyang
Ahmed Hamdy
Hangxiang Yu (binding)
Zakelly Lan (binding)
Yuan Mei (binding)
No one against.
[1] https://cwiki.apache.org/confl
Thank you all for the discussion and voting. Voting is closed.
Best,
Zakelly
On Wed, Aug 21, 2024 at 4:54 PM Yuan Mei wrote:
> +1
>
> Thanks for driving this, Zakelly!
>
> Best
> Yuan
>
> On Wed, Aug 21, 2024 at 11:24 AM Zakelly Lan
> wrote:
>
> > +1 (binding)
> >
> > Best,
> > Zakelly
> >
>
Zakelly Lan created FLINK-36120:
---
Summary: Internal APIs for declaring and defining the record
processing
Key: FLINK-36120
URL: https://issues.apache.org/jira/browse/FLINK-36120
Project: Flink
Zakelly Lan created FLINK-36121:
---
Summary: Snapshot the in-flight async state requests
Key: FLINK-36121
URL: https://issues.apache.org/jira/browse/FLINK-36121
Project: Flink
Issue Type: Sub-tas
Zakelly Lan created FLINK-36119:
---
Summary: Conditional branchings APIs under `StateFuture`
Key: FLINK-36119
URL: https://issues.apache.org/jira/browse/FLINK-36119
Project: Flink
Issue Type: Sub
Zakelly Lan created FLINK-36118:
---
Summary: FLIP-455: Declare async state processing and checkpoint
the in-flight requests
Key: FLINK-36118
URL: https://issues.apache.org/jira/browse/FLINK-36118
Project:
wang qian created FLINK-36117:
-
Summary: Implement AsyncKeyedStateBackend for
RocksDBKeyedStateBackend and HeapKeyedStateBackend.
Key: FLINK-36117
URL: https://issues.apache.org/jira/browse/FLINK-36117
Pr
+1
Thanks for driving this, Zakelly!
Best
Yuan
On Wed, Aug 21, 2024 at 11:24 AM Zakelly Lan wrote:
> +1 (binding)
>
> Best,
> Zakelly
>
> On Thu, Aug 15, 2024 at 9:02 PM Hangxiang Yu wrote:
>
> > +1 (binding)
> >
> > Thanks for driving this.
> >
> > On Thu, Aug 15, 2024 at 8:42 PM Ahmed Hamdy
Hi Flink Devs,
Thank you for all the feedback about FLIP-477: Amazon SQS Source Connector
[1]. The discussion thread can be found here [2].
The vote will be open for at least 72 hours unless there are any objections
or insufficient votes.
Regards,
Abhi & Saurabh
[1]
https://cwiki.apache.org/con
Martijn Visser created FLINK-36116:
--
Summary: Javadocs aren't visible anymore for Flink 1.17 and above
Key: FLINK-36116
URL: https://issues.apache.org/jira/browse/FLINK-36116
Project: Flink
26 matches
Mail list logo
