Quan Limin created FLINK-37299:
--
Summary: flink stateless startup cannot continue consuming from
the current location of the consumer group
Key: FLINK-37299
URL: https://issues.apache.org/jira/browse/FLINK-37299
Follow the above,
"And for SinkWriter, the data structure to be processed should be fixed."
I'm not very sure why the data structure of SinkWriter should be fixed. Can
you elaborate the scenario here?
"Is there a node or an operator to fill in the inconsistent field of
Rowdata that passed from
Link for Paimon LocalMerge Operator[1]
[1]
https://paimon.apache.org/docs/master/maintenance/write-performance/#local-merging
xiangyu feng 于2025年2月11日周二 14:03写道：
> Follow the above,
>
> "And for SinkWriter, the data structure to be processed should be fixed."
>
> I'm not very sure why the data
Hi Yanquan,
Thx for reply. IIUC, the schema of CatalogTable should contain all target
columns for sources. If not, a SQL validation exception should be raised
for planner.
Regards,
Xiangyu Feng
Yanquan Lv 于2025年2月10日周一 16:25写道：
> Hi, Xiangyu. Thanks for driving this.
>
> I have a question to
Poorvank Bhatia created FLINK-37298:
---
Summary: Custom Batch Handling in AsyncSink
Key: FLINK-37298
URL: https://issues.apache.org/jira/browse/FLINK-37298
Project: Flink
Issue Type: Improvem
awesome
Thanks a lot Leonard!
continued today.
The things still need to do rest is release promotion and merging web PR
I will do it tomorrow since it is recommended to wait about 24 hours
On Mon, Feb 10, 2025 at 4:40 AM Leonard Xu wrote:
> Hey, Sergey
>
> DONE via [1][2], please go on your rel
Hi Yash,
+1 for the proposal.
Thanks,
Hao
On Mon, Feb 10, 2025 at 12:31 AM Yanquan Lv wrote:
> Hi, Yash. Thanks for driving it.
> +1 for this.
>
> > 2025年2月7日 05:28，Yash Anand 写道：
> >
> > Hi all! I would like to open up for discussion a new FLIP-507[1].
> > Motivation This proposal aims to ex
Daniel Lopes created FLINK-37297:
Summary: Either type Pojo deserialization fails with NPE
Key: FLINK-37297
URL: https://issues.apache.org/jira/browse/FLINK-37297
Project: Flink
Issue Type: B
kyle n created FLINK-37296:
--
Summary: Add ability to add File Level Header in the File Sink
forRowFormat
Key: FLINK-37296
URL: https://issues.apache.org/jira/browse/FLINK-37296
Project: Flink
Issue
The next release sync will be held at the following time.
- 15:00, Feb 12, BJT (GMT+8)
- 08:00, Feb 12, CET (GMT+1)
- 23:00, Feb 11, PT (GMT-8)
Everyone is welcome to join via Google Meet [1]. The topics to be discussed
can be found at the Status / Follow-ups section of the release wiki page
[2].
xiangyu feng created FLINK-37294:
Summary: Support state migration between disabling and enabling
ttl in HeapKeyedStateBackend
Key: FLINK-37294
URL: https://issues.apache.org/jira/browse/FLINK-37294
P
xiangyu feng created FLINK-37295:
Summary: Update state ttl migration compatibility in docs
Key: FLINK-37295
URL: https://issues.apache.org/jira/browse/FLINK-37295
Project: Flink
Issue Type:
He Wang created FLINK-37293:
---
Summary: Length of Binary type is missing in OceanBase pipeline
connector
Key: FLINK-37293
URL: https://issues.apache.org/jira/browse/FLINK-37293
Project: Flink
Issue
Wenkai Qi created FLINK-37292:
-
Summary: The Flink-Kubernetes dependency embedded in the packaging
of flink-cdc-dist is incompatible with Flink 1.20.
Key: FLINK-37292
URL: https://issues.apache.org/jira/browse/FLINK-3
Hi, Yash. Thanks for driving it.
+1 for this.
> 2025年2月7日 05:28，Yash Anand 写道：
>
> Hi all! I would like to open up for discussion a new FLIP-507[1].
> Motivation This proposal aims to extend model DDL support to the Table API,
> enabling a seamless development experience where users can define,
Hi, Xiangyu. Thanks for driving this.
I have a question to confirm:
Considering the case that different Sources use different columns[1], will the
Schema of CatalogTable[2] contain all target columns for Sources?
And for SinkWriter, the data structure to be processed should be fixed. Is
there a
16 matches
Mail list logo
