Hi Flink devs,
I would like to start a discussion on FLIP-447: Upgrade FRocksDB from
6.20.3 to 8.10.0
https://cwiki.apache.org/confluence/display/FLINK/FLIP-447%3A+Upgrade+FRocksDB+from+6.20.3++to+8.10.0
This FLIP proposes upgrading the version of FRocksDB in the Flink Project
from 6.20.3 to
Hi, Dev
I'm happy to announce that FLIP-435: Introduce a New Materialized Table for
Simplifying Data Pipelines[1] has been accepted with 13 approving votes (8
binding) [2]
- Ron Liu(binding)
- Feng Jin
- Rui Fan(binding)
- Yuepeng Pan
- Ahmed Hamdy
- Ferenc Csaky
- Lincoln Lee(binding)
- Leonard
Hi, Dev
I would like to start a discussion about FLIP-448: Introduce Pluggable
Workflow Scheduler Interface for Materialized Table.
In FLIP-435[1], we proposed Materialized Table, which has two types of data
refresh modes: Full Refresh & Continuous Refresh Mode. In Full Refresh
mode, the
dalongliu created FLINK-35191:
-
Summary: Support alter materialized table related syntaxes:
suspend, resume, refresh, set and reset
Key: FLINK-35191
URL: https://issues.apache.org/jira/browse/FLINK-35191
dalongliu created FLINK-35194:
-
Summary: Support describe job syntax
Key: FLINK-35194
URL: https://issues.apache.org/jira/browse/FLINK-35194
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-35195:
-
Summary: Support the execution of materialized table in continuous
mode
Key: FLINK-35195
URL: https://issues.apache.org/jira/browse/FLINK-35195
Project: Flink
dalongliu created FLINK-35205:
-
Summary: Support the execution of alter materialized table reset
options
Key: FLINK-35205
URL: https://issues.apache.org/jira/browse/FLINK-35205
Project: Flink
Wenbing Shen created FLINK-35196:
Summary: bouncycastle class not found for flink pulsar connector
Key: FLINK-35196
URL: https://issues.apache.org/jira/browse/FLINK-35196
Project: Flink
Thanks Danny,
+1 (non-binding)
- Verified Checksums
- Verified Signatures
- No binaries exists in source archive
- Built source
- Reviewed Web PR
- Run basic Kinesis example
Best Regards
Ahmed Hamdy
On Sun, 21 Apr 2024 at 14:25, Hang Ruan wrote:
> +1 (non-binding)
>
> - Validated checksum
dalongliu created FLINK-35193:
-
Summary: Support drop materialized table syntax and execution
Key: FLINK-35193
URL: https://issues.apache.org/jira/browse/FLINK-35193
Project: Flink
Issue Type:
Dian Fu created FLINK-35208:
---
Summary: Respect pipeline.cached-files during processing Python
dependencies
Key: FLINK-35208
URL: https://issues.apache.org/jira/browse/FLINK-35208
Project: Flink
dalongliu created FLINK-35190:
-
Summary: Support the syntaxes of Create, Suspend, Resume, Refresh
and Drop materialized table
Key: FLINK-35190
URL: https://issues.apache.org/jira/browse/FLINK-35190
dalongliu created FLINK-35201:
-
Summary: Support the execution of drop materialized table in full
refresh mode
Key: FLINK-35201
URL: https://issues.apache.org/jira/browse/FLINK-35201
Project: Flink
dalongliu created FLINK-35200:
-
Summary: Support the execution of suspend, resume materialized
table in full refresh mode
Key: FLINK-35200
URL: https://issues.apache.org/jira/browse/FLINK-35200
Project:
dalongliu created FLINK-35203:
-
Summary: Support the execution of alter materialized table set
refresh mode
Key: FLINK-35203
URL: https://issues.apache.org/jira/browse/FLINK-35203
Project: Flink
chenyuzhi created FLINK-35192:
-
Summary: operator oom
Key: FLINK-35192
URL: https://issues.apache.org/jira/browse/FLINK-35192
Project: Flink
Issue Type: Bug
Components: Kubernetes
dalongliu created FLINK-35199:
-
Summary: Support the execution of create materialized table in
full refreshmode
Key: FLINK-35199
URL: https://issues.apache.org/jira/browse/FLINK-35199
Project: Flink
dalongliu created FLINK-35204:
-
Summary: Support the execution of alter materialized table set
options
Key: FLINK-35204
URL: https://issues.apache.org/jira/browse/FLINK-35204
Project: Flink
Zakelly Lan created FLINK-35186:
---
Summary: Create State V2 from new StateDescriptor
Key: FLINK-35186
URL: https://issues.apache.org/jira/browse/FLINK-35186
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-35188:
-
Summary: Introduce CatalogMaterializedTable and related interface
to support materialized table
Key: FLINK-35188
URL: https://issues.apache.org/jira/browse/FLINK-35188
Ryan Skraba created FLINK-35207:
---
Summary: Kubernetes session E2E test fails to fetch packages.
Key: FLINK-35207
URL: https://issues.apache.org/jira/browse/FLINK-35207
Project: Flink
Issue
dalongliu created FLINK-35189:
-
Summary: Introduce test-filesystem Catalog based on FileSystem
Connector to support materialized table
Key: FLINK-35189
URL: https://issues.apache.org/jira/browse/FLINK-35189
dalongliu created FLINK-35198:
-
Summary: Support the execution of refresh materialized table
Key: FLINK-35198
URL: https://issues.apache.org/jira/browse/FLINK-35198
Project: Flink
Issue Type:
dalongliu created FLINK-35197:
-
Summary: Support the execution of suspend, resume materialized
table in continuous mode
Key: FLINK-35197
URL: https://issues.apache.org/jira/browse/FLINK-35197
Project:
Hello devs,
I would like to start a discussion about FLIP-XXX: Support
currentFetchEventTimeLag and processingLag metrics [1].
The main motivation for this change was that I had some difficulties in
implementing the currentFetchEventTimeLag metrics for KafkaSource [2]. So I
proposed to let the
dalongliu created FLINK-35187:
-
Summary: FLIP-435: Introduce a New Materialized Table for
Simplifying Data Pipelines
Key: FLINK-35187
URL: https://issues.apache.org/jira/browse/FLINK-35187
Project: Flink
dalongliu created FLINK-35202:
-
Summary: Support the execution of set freshness for materialized
table
Key: FLINK-35202
URL: https://issues.apache.org/jira/browse/FLINK-35202
Project: Flink
dalongliu created FLINK-35206:
-
Summary: Desc table syntax support materialized table
Key: FLINK-35206
URL: https://issues.apache.org/jira/browse/FLINK-35206
Project: Flink
Issue Type: Sub-task
Hi Martijn,
A gentle nudge, is this ok for you or one of the PMC or committers to create a
Flip now?
Kind regards, David.
From: David Radley
Date: Monday, 15 April 2024 at 12:29
To: dev@flink.apache.org
Subject: Re: [EXTERNAL] RE: [DISCUSS] FLIP-XXX Apicurio-avro format
Hi Martijn,
Hi everyone,
Please review and vote on release candidate #1 for flink-connector-kafka
v3.2.0, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
This release supports Flink 1.18 and 1.19.
The complete staging area is available for your
Hi all,
Thank you all! Closing the vote. The result will be announced in a
separate email.
Best regards,
Xuannan
On Fri, Apr 19, 2024 at 10:58 AM gongzhongqiang
wrote:
>
> +1 (non-binding)
>
>
> Best,
> Zhongqiang Gong
>
> Xuannan Su 于2024年4月17日周三 13:02写道：
>
> > Hi everyone,
> >
> > Thanks
Sorry all, it seems bad formatting in my email message, now I send it again
gently and hope it work.
I would like to start a discussion about FLIP-XXX:
SupportcurrentFetchEventTimeLag and processingLag metrics [1].
The main motivation for this change was that I had some difficulties
Hi devs,
I'm happy to announce that FLIP-442: General Improvement to
Configuration for Flink 2.0[1] has been accepted with 9 approving
votes (4 bindings) [2]:
- Rui Fan (binding)
- Zakelly Lan (binding)
- Xintong Song (binding)
- Yuxin Tan (non-binding)
- Zhu Zhu (binding)
- Jeyhun Karimov
Hi everyone,
Please review and vote on release candidate #1 for
flink-connector-cassandra v3.2.0, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
This release supports Flink 1.18 and 1.19.
The complete staging area is available for
Nicolas Perrin created FLINK-35209:
--
Summary: Add a DeserializationSchema decorator that counts
deserialize errors
Key: FLINK-35209
URL: https://issues.apache.org/jira/browse/FLINK-35209
Project:
Nicolas Perrin created FLINK-35210:
--
Summary: Give the option to set automatically the parallelism of
the KafkaSource to the number of kafka partitions
Key: FLINK-35210
URL:
wangsw created FLINK-35211:
--
Summary: when synchronize LOB fields using oracle cdc, an error
occurs
Key: FLINK-35211
URL: https://issues.apache.org/jira/browse/FLINK-35211
Project: Flink
Issue
Hi,
Thanks for writing the proposal and preparing the upgrade.
FRocksDB definitely needs to be kept in sync with the upstream and the new
APIs are necessary for faster rescaling.
We're already using a similar version internally.
I reviewed the FLIP and it looks good to me (disclaimer: I took
LvYanquan created FLINK-35213:
-
Summary: A potential inconsistent table structure issue
Key: FLINK-35213
URL: https://issues.apache.org/jira/browse/FLINK-35213
Project: Flink
Issue Type:
Thanks Yue for driving this proposal!
This upgrade makes sense, +1 for that.
Best,
Rui
On Tue, Apr 23, 2024 at 12:06 PM Roman Khachatryan wrote:
> Hi,
>
> Thanks for writing the proposal and preparing the upgrade.
>
> FRocksDB definitely needs to be kept in sync with the upstream and the new
Rui Fan created FLINK-35215:
---
Summary: The performance of serializerKryo and
serializerKryoWithoutRegistration are regressed
Key: FLINK-35215
URL: https://issues.apache.org/jira/browse/FLINK-35215
Project:
Yuxin Tan created FLINK-35214:
-
Summary: Update result partition id for remote input channel when
unknown input channel is updated
Key: FLINK-35214
URL: https://issues.apache.org/jira/browse/FLINK-35214
Thanks Danny, +1 (non-binding)
- Checked 512 hash
- Checked gpg signature
- Reviewed pr
- Built the source with JDK 11 & 8
Best,
Muhammet
On 2024-04-22 13:55, Danny Cranmer wrote:
Hi everyone,
Please review and vote on release candidate #1 for
flink-connector-kafka
v3.2.0, as follows:
[ ]
Wei Yuan created FLINK-35212:
Summary: PyFlink thread mode process just can run once in
standalonesession mode
Key: FLINK-35212
URL: https://issues.apache.org/jira/browse/FLINK-35212
Project: Flink
Thanks! +1 (non-binding)
- Checked 512 hash
- Checked gpg signature
- Reviewed web pr & release notes
- Built the source with JDK 11 & 8
Best,
Muhammet
On 2024-04-22 13:04, Danny Cranmer wrote:
Hi everyone,
Please review and vote on release candidate #1 for
flink-connector-cassandra v3.2.0,
Hi Yue & Roman,
Thanks for initiating this FLIP and all the efforts for the upgrade.
8.10.0 introduces some new features, making it possible for Flink to
implement some new exciting features, and the upgrade also makes
FRocksDB easier to maintain, +1 for upgrading.
I read the FLIP and have a
Hi Yue,
Thanks for driving this work.
It has been three years since last major upgrade of FRocksDB. And it would be
great improvement of Flink's state-backend with this upgrade. +1 for this work.
Best
Yun Tang
From: Yanfei Lei
Sent: Tuesday, April 23, 2024
47 matches
Mail list logo
