Hi, Siva.
You can use this link[1] to join Flink community on Slack.
We will update the link on getting-help page later.
[1]
https://apache-flink.slack.com/join/shared_invite/zt-36qpbfpc0-wtlsC7lmeEUy5cw0VTHdag#/shared-invite/email
Siva Ram Gujju 于2025年5月29日周四 02:30写道：
> Hello,
>
> The invite
Yanquan Lv created FLINK-37855:
--
Summary: Reduce the time cost in MySqlSchemaUtils#listTables
Key: FLINK-37855
URL: https://issues.apache.org/jira/browse/FLINK-37855
Project: Flink
Issue Type
sorry for the title and update:
[Discuss] Flink CDC 3.5 Kick Off
Yanquan Lv 于2025年5月27日周二 11:36写道：
> Hi devs,
>
> As FlinkCDC 3.4 was released recently, it's a good time to kick off the
> upcoming Flink CDC 3.5 release cycle.
>
> In the past two major versions, w
Hi devs,
As FlinkCDC 3.4 was released recently, it's a good time to kick off the
upcoming Flink CDC 3.5 release cycle.
In the past two major versions, we have made significant optimizations to
the capability of schema evolution, this feature is quite stable now. In
this version, we will focus on
Yanquan Lv created FLINK-37847:
--
Summary: [umbrella] Unstable test in FlinkCDC project
Key: FLINK-37847
URL: https://issues.apache.org/jira/browse/FLINK-37847
Project: Flink
Issue Type
Yanquan Lv created FLINK-37846:
--
Summary: [Unstable test]
MysqlToKafkaE2eITCase.testSyncWholeDatabaseWithDebeziumJson
Key: FLINK-37846
URL: https://issues.apache.org/jira/browse/FLINK-37846
Project
Yanquan Lv created FLINK-37837:
--
Summary: Always Add create.table to include.schema.changes option
Key: FLINK-37837
URL: https://issues.apache.org/jira/browse/FLINK-37837
Project: Flink
Issue
The Apache Flink community is very happy to announce the release of
Apache Flink CDC 3.4.0.
Apache Flink CDC is a distributed data integration tool for real time
data and batch data, bringing the simplicity and elegance of data
integration via YAML to describe the data movement and transformation
I'm happy to announce that we have unanimously approved this release.
There are 9 approving votes, 4 of which are binding:
* Xiqian YU non-binding
* Ferenc Csaky non-binding
* Tianzhu non-binding
* ouyangwulin non-binding
* Leonard Xu binding
* Zakelly Lan binding
* Xingbo Huang binding
*
Yanquan Lv created FLINK-37786:
--
Summary: Infer schema information from the state of Source and
emit it to avoid maintaining state in PreTransform
Key: FLINK-37786
URL: https://issues.apache.org/jira/browse/FLINK
gt; > >
> > > >
> > > > Best,
> > > > Zakelly
> > > >
> > > > On Wed, May 7, 2025 at 10:57 AM Leonard Xu
> wrote:
> > > >
> > > > > +1 (binding)
> > > > >
> > > > > - verified
Hi everyone,
Please review and vote on the release candidate #3 for the version 3.4.0 of
Apache Flink CDC,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
*Release Overview*
As an overview, the release consists of the following:
a) Flink
merged.
> >
> > [1] https://issues.apache.org/jira/browse/FLINK-37104
> > [2] https://issues.apache.org/jira/browse/FLINK-37738
> > [3]
> >
> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12355589
> >
> > Best
>
Yanquan Lv created FLINK-37743:
--
Summary: Add benchmark test for Flink CDC Pipeline job
Key: FLINK-37743
URL: https://issues.apache.org/jira/browse/FLINK-37743
Project: Flink
Issue Type
Hi everyone,
Please review and vote on the release candidate #2 for the version 3.4.0 of
Apache Flink CDC,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
*Release Overview*
As an overview, the release consists of the following:
a) Flin
but seems it’s still
> labeled as 3.4-SNAPSHOT. Maybe we should recompile it with the latest
> release-3.4 branch?
>
> Best Regards,
> Xiqian
>
> > 2025年4月27日 17:33，Yanquan Lv 写道：
> >
> > Hi everyone,
> >
> > Please review and vote on the release can
Hi everyone,
Please review and vote on the release candidate #1 for the version 3.4.0 of
Apache Flink CDC,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
*Release Overview*
As an overview, the release consists of the following:
a) Fl
Hi everyone,
Flink CDC v3.4.0 [1] has already updated Flink dependency to 1.20, added
Iceberg pipeline sink and introduced many important features like Batch
execution mode.
The major development work we mentioned in the 3.4.0 kick off has been
completed. and I think it's a good time to start the
Yanquan Lv created FLINK-37734:
--
Summary: Update version to 3.5-SNAPSHOT and update related docs
Key: FLINK-37734
URL: https://issues.apache.org/jira/browse/FLINK-37734
Project: Flink
Issue
Yanquan Lv created FLINK-37731:
--
Summary: Update dependency of Paimon to 1.1 and add support for
Postpone Bucket
Key: FLINK-37731
URL: https://issues.apache.org/jira/browse/FLINK-37731
Project: Flink
Yanquan Lv created FLINK-37726:
--
Summary: Read incremental data for existing tables
Key: FLINK-37726
URL: https://issues.apache.org/jira/browse/FLINK-37726
Project: Flink
Issue Type
Yanquan Lv created FLINK-37713:
--
Summary: SchemaManager was recreated in SchemaRegistry after job
failover
Key: FLINK-37713
URL: https://issues.apache.org/jira/browse/FLINK-37713
Project: Flink
Yanquan Lv created FLINK-37712:
--
Summary: Table
Key: FLINK-37712
URL: https://issues.apache.org/jira/browse/FLINK-37712
Project: Flink
Issue Type: Bug
Reporter: Yanquan Lv
Gentle ping for more binding votes.
Tom Cooper 于2025年4月17日周四 20:09写道：
> Hi Arvid,
>
> Thanks for looking at this. I can confirm that updated sources now compile
> on my Fedora box. I still get the following warning when running tar -xf:
>
> tar: Ignoring unknown extended header keyword
> 'LIBARC
+1 (non-binding)
I checked:
- Review JIRA release notes
- Verify hashes and verify signatures
- Build success from source with JDK8 & maven3.8.6
- Source code artifacts matching the current release
- Read the announcement blog
- Check all CI action passing
Hang Ruan 于2025年4月17日周四 20:37写道：
> Hi e
Yanquan Lv created FLINK-37699:
--
Summary: Overwrite the parameters of the created Paimon table
through table options
Key: FLINK-37699
URL: https://issues.apache.org/jira/browse/FLINK-37699
Project
Hi, Hang.
I found that there is a failure in Flink Connector JDBC CI Backwards
Compatibility[1], and the cause is pom.xml of
flink-connector-jdbc-backward-compatibility is still 4.0-SNAPSHOT. We need
to modify it to the correct version, so I -1 for this.
[1] https://github.com/apache/flink-connect
Congratulations！
Best,
Yanquan
Jiabao Sun 于2025年4月16日周三 20:25写道：
> Congrats Xiqian!
>
> Best,
> Jiabao
>
> On 2025/04/16 07:25:19 Leonard Xu wrote:
> > Hi everyone,
> >
> > On behalf of the PMC, I'm happy to let you know that Xiqian Yu has
> become a new Flink Committer!
> >
> > Since joining t
Yanquan Lv created FLINK-37676:
--
Summary: Add a cache for TableId in Selector to improve performance
Key: FLINK-37676
URL: https://issues.apache.org/jira/browse/FLINK-37676
Project: Flink
Issue
Yanquan Lv created FLINK-37673:
--
Summary: The transformation of table metadata should only be
effective for the first matching rule
Key: FLINK-37673
URL: https://issues.apache.org/jira/browse/FLINK-37673
Yanquan Lv created FLINK-37667:
--
Summary: Make PostTransformOperator always chain with before
Operator
Key: FLINK-37667
URL: https://issues.apache.org/jira/browse/FLINK-37667
Project: Flink
+1 (non-binding)
I checked:
- Review JIRA release notes
- Verify hashes and verify signatures
- Build success from source with JDK17 & maven3.8.6
- Source code artifacts matching the current release
- Read the announcement blog and LGTM
- Run a sql test for Kafka Source & Sink with Flink 2.0 clust
+1 (non-binding)
I checked:
- Review JIRA release notes
- Verify hashes and verify signatures
- Build success from source with JDK17 & maven3.8.6
- Source code artifacts matching the current release
- Read the announcement blog and LGTM
- Run a datagen to elasticsearch7 test with Flink 2.0 cluster
to a unique prefix
> (e.g. org.apache.flink.connector.kafka).
> Then SQL module will simply use that relocation transitively.
> WDYT?
>
> Best,
>
> Arvid
>
> On Wed, Apr 9, 2025 at 6:38 PM Yanquan Lv wrote:
>
> > I checked:
> > - Review JIRA release notes
+1 (non-binding)
I checked:
- Review JIRA release notes
- Verify hashes and verify signatures
- Build success from source with JDK8 & maven3.8.6
- Source code artifacts matching the current release
- Read the announcement blog
Hang Ruan 于2025年4月10日周四 11:57写道：
> Hi everyone,
> Please review and v
Yanquan Lv created FLINK-37644:
--
Summary: Include guava dependency to package of Kafka connector
release and shade
Key: FLINK-37644
URL: https://issues.apache.org/jira/browse/FLINK-37644
Project: Flink
I checked:
- Review JIRA release notes
- Verify hashes and verify signatures
- Build success from source with JDK17 & maven3.8.6
- Source code artifacts matching the current release
- Read the announcement blog
- Verify that the major version is 55
I am trying to use the jar flink-sql-connector-k
Hi, Weijie.
Sorry for reply again, But I found that the major version of the release
jar is 52 using `javap -classpath
flink-sql-connector-elasticsearch7-4.0.0-2.0.jar -verbose
org.apache.flink.connector.elasticsearch.Elasticsearch7ApiCallBridge | grep
version`, Is this not as expected? Do we need
> 1.17...).
>
> Anyway, what you mentioned is really a meaningful feature, but I would
> prefer to include it in next release. WDYT?
>
>
> Best regards,
>
> Weijie
>
>
> Yanquan Lv 于2025年4月9日周三 11:30写道：
>
> > I checked:
> > - Review JIRA re
Sorry for the previous conclusion, I have confirmed again and found that
the major version is 52, as you and Xiqian mentioned.
But fortunately, we can confirm and discover the actual problem.
Arvid Heise 于2025年4月8日周二 22:09写道：
> Hi everyone,
> Please review and vote on release candidate #1 for fl
+1 (non-binding)
I checked:
- Review JIRA release notes
- Verify hashes and verify signatures
- Build success from source with JDK11 & maven3.8.6
- Source code artifacts matching the current release
- Read the announcement blog and LGTM
Ferenc Csaky 于2025年3月28日周五 21:34写道：
> Hi everyone,
>
> Ple
+1 (non-binding)
I checked:
- Review JIRA release notes
- Verify hashes and verify signatures
- Build success from source with JDK11 & maven3.8.6
- Source code artifacts matching the current release
- Read the announcement blog and LGTM
- Run a datagen to elasticsearch7 test with Flink 2.0 cluster
Yanquan Lv created FLINK-37636:
--
Summary: Weekly CI failure
Key: FLINK-37636
URL: https://issues.apache.org/jira/browse/FLINK-37636
Project: Flink
Issue Type: Improvement
Components
Hi, Arvid. Thanks for your efforts in this release.
I noticed that this released version was compiled using JDK 17, and there
is also flink-connector-elasticsearch[1] support for Flink 2.0 release,
which is compiled using JDK 11.
I checked the compiled version of Flink 2.0 release, which is also j
I checked:
- Review JIRA release notes
- Verify hashes and verify signatures
- Build success from source with JDK11 & maven3.8.6
- Source code artifacts matching the current release
- Read the announcement blog and LGTM
I noticed that we have supported ElasticSearch8 in this release and
provided t
Congrations, Sergey!
Best, Yanquan
> 2025年4月3日 14:54，Dawid Wysakowicz 写道：
>
> On behalf of the PMC, I'm very happy to announce a new Apache Flink PMC
> Member
> - Sergey Nuyanzin.
>
> Sergey has been a dedicated and invaluable contributor to the Flink
> community for several years. He became a
State is there to support situations where MDS is not accessible, it
> stores the cached metadata in the state
>
> I hope it clarifies,
> Matyas
>
> On Sat, Apr 5, 2025 at 9:55 AM Yanquan Lv wrote:
>
> > Hi, Matyas. Thanks for driving this.
> > I have some ques
Hi, Matyas. Thanks for driving this.
I have some questions and I hope you can help explain them:
1. The dynamic Kafka Sink looks like only be used in DataStream jobs
currently, will it be considered to be supported in TableAPI in the future?
2. Even though we have Kafka MetaData Service, due to th
Congrats, Zakelly!
Best, Yanquan.
> 2025年4月1日 15:51，Yuan Mei 写道：
>
> On behalf of the PMC, I'm very happy to announce a new Apache Flink PMC Member
> - Zakelly Lan.
>
> Zakelly has been a dedicated and invaluable contributor to the Flink
> community for over five years. He became a committer e
Hi, Cooper. Thank you for bringing up the discussion about Kafka 4.0.0.
I tend to release Kafka Connector 4.0 with Flink 2.0.0 and Kafka 3.9.0, or
Kafka 3.8.1 if If the community is concerned about 3.9.0.
Here are some of my opinions:
1. The plan for Kafka Connector 4.0.0 was proposed[1] a long
Yanquan Lv created FLINK-37590:
--
Summary: Update the code of Python modules to adapt to Flink 2.0's
pyFlink
Key: FLINK-37590
URL: https://issues.apache.org/jira/browse/FLINK-37590
Project:
Yanquan Lv created FLINK-37587:
--
Summary: Fail to add a new column that has the same column name
with source table using transform
Key: FLINK-37587
URL: https://issues.apache.org/jira/browse/FLINK-37587
Yanquan Lv created FLINK-37577:
--
Summary: Wait compaction only when table set
deletion-vectors.enabled to true in PaimonWriter
Key: FLINK-37577
URL: https://issues.apache.org/jira/browse/FLINK-37577
Yanquan Lv created FLINK-37572:
--
Summary: Shuffle Event by bucket and tableid to avoid data skew
Key: FLINK-37572
URL: https://issues.apache.org/jira/browse/FLINK-37572
Project: Flink
Issue
Yanquan Lv created FLINK-37566:
--
Summary: table.exclude was invalid in binlog reading phase when
scan.binlog.newly-added-table.enabled
Key: FLINK-37566
URL: https://issues.apache.org/jira/browse/FLINK-37566
Yanquan Lv created FLINK-37539:
--
Summary: performance optimization in Paimon Sink to reduce
end-to-end checkpoint time
Key: FLINK-37539
URL: https://issues.apache.org/jira/browse/FLINK-37539
Project
Yanquan Lv created FLINK-37519:
--
Summary: Add clearer logs when fail to write to YAML DataSink.
Key: FLINK-37519
URL: https://issues.apache.org/jira/browse/FLINK-37519
Project: Flink
Issue Type
+1 (non-binding)
- Verified signatures and sha512
- Compiled the project with java 17 and maven 3.8.6
- Ran a sql test for filesystem connector with csv format in standalone cluster
and it worked as expected
> 2025年3月10日 17:05，Xintong Song 写道：
>
> Hi everyone,
>
> There were some blocker issu
Yanquan Lv created FLINK-37462:
--
Summary: Unstable test case in
FlinkParallelizedPipelineITCase.testRegularTablesSourceInMultipleParallelism
Key: FLINK-37462
URL: https://issues.apache.org/jira/browse/FLINK-37462
Yanquan Lv created FLINK-37461:
--
Summary: Unstable test case in
MySqlToPaimonE2eITCase#testSyncWholeDatabase
Key: FLINK-37461
URL: https://issues.apache.org/jira/browse/FLINK-37461
Project: Flink
Yanquan Lv created FLINK-37452:
--
Summary: Add support for writing to Paimon Append only table.
Key: FLINK-37452
URL: https://issues.apache.org/jira/browse/FLINK-37452
Project: Flink
Issue Type
Yanquan Lv created FLINK-37386:
--
Summary: Avoid sending too much CreateTableEvents when job
failover
Key: FLINK-37386
URL: https://issues.apache.org/jira/browse/FLINK-37386
Project: Flink
Congratulations, Xuyang!
Best, Yanquan.
> 2025年2月20日 10:24，Zakelly Lan 写道：
>
> Congratulations, Xuyang!
Yanquan Lv created FLINK-37353:
--
Summary: [Doc] Add doc for
scan.incremental.snapshot.chunk.key-column Mysql Data Sink
Key: FLINK-37353
URL: https://issues.apache.org/jira/browse/FLINK-37353
Project
Yanquan Lv created FLINK-37352:
--
Summary: Write full changelog to Paimon Sink.
Key: FLINK-37352
URL: https://issues.apache.org/jira/browse/FLINK-37352
Project: Flink
Issue Type: Improvement
Yanquan Lv created FLINK-37349:
--
Summary: Add timeout for test case that call waitForSinkSize
method to avoid Infinite waiting
Key: FLINK-37349
URL: https://issues.apache.org/jira/browse/FLINK-37349
Yanquan Lv created FLINK-37346:
--
Summary: [CI] Unit Tests (mysql) / compile_and_test (8, generic)
(pull_request)Failing after 60m
Key: FLINK-37346
URL: https://issues.apache.org/jira/browse/FLINK-37346
support. Yes and support for the new dialects.
>>>>>
>>>>> It would be great to get open PRs merged to support new dialect if
>>>>> possible, including:
>>>>> https://github.com/apache/flink-connector-jdbc/pull/118 - this has
>>> been
&g
imately). I'd leave that decision to
>>> the two release managers for 4.0.0 mentioned before.
>>>
>>> One thing to note for 4.0.0 is that we need to solve the transaction
>>> management issues with the KafkaSink [2]. It's blocking larger users from
>>
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
Yanquan Lv created FLINK-37285:
--
Summary: Adapt DataSinkTranslator to support new Sink API of
FLIP-372
Key: FLINK-37285
URL: https://issues.apache.org/jira/browse/FLINK-37285
Project: Flink
Yanquan Lv created FLINK-37277:
--
Summary: Add guidance for configuring different kind of catalog of
Paimon Sink.
Key: FLINK-37277
URL: https://issues.apache.org/jira/browse/FLINK-37277
Project: Flink
Hi, Fabrizzio.
Are you referring to this connector? It has already been independently
iterated as an external connector repository:
https://github.com/apache/flink-connector-rabbitmq
Fabrizzio Chávez Tejada 于2025年2月6日周四 16:27写道：
> Hello everyone, I am new in this channel, so I hope to understan
+1 (non-binding)
I checked:
- Review JIRA release notes
- Verify hashes and verify signatures
- Build success from source with JDK8/11 & maven3.8.6
- Source code artifacts matching the current release
- Read the announcement blog and LGTM
Leonard Xu 于2025年2月6日周四 15:06写道：
> +1 (binding)
>
> - bui
Yanquan Lv created FLINK-37252:
--
Summary: Align Chinese document of Postgres CDC Connector with
English document
Key: FLINK-37252
URL: https://issues.apache.org/jira/browse/FLINK-37252
Project: Flink
Yanquan Lv created FLINK-37251:
--
Summary: Add download link for pipeline connector.
Key: FLINK-37251
URL: https://issues.apache.org/jira/browse/FLINK-37251
Project: Flink
Issue Type: Technical
+1 (non-binding)
I checked:
- Review JIRA release notes
- Verify hashes and verify signatures
- Build success from source with JDK8/11/17 & maven3.8.6
- Source code artifacts matching the current release
- Read the announcement blog and left one comment
Sergey Nuyanzin 于2025年2月3日周一 07:35写道：
> H
+1 (non-binding)
I checked:
- Review JIRA release notes
- Verify hashes and verify signatures
- Build success from source with JDK11 & maven3.8.6
- Source code artifacts matching the current release
- Read the announcement blog and LGTM
- Run a wordcount example in standalone cluster mode
Alexand
find fresh data. What it configures is
how often the FHS polls the remote data store for new files. The remote
data store is written to whenever a job is finished.
Hope this clarifies some things.
Best,
- Allison
On Mon, Jan 27, 2025 at 7:10 PM Yanquan Lv wrote:
> Hi, Allison. Thanks for driv
+1 (non-binding)
I checked:
- Review JIRA release notes
- Verify hashes and verify signatures
- Build success from source with JDK11 & maven3.8.6
- Source code artifacts matching the current release
- Read the announcement blog and LGTM
-- Forwarded message -
发件人： Alexander Fedulo
Yanquan Lv created FLINK-37235:
--
Summary: Add e2e test for flink-connector-elasticsearch8
Key: FLINK-37235
URL: https://issues.apache.org/jira/browse/FLINK-37235
Project: Flink
Issue Type
Yanquan Lv created FLINK-37234:
--
Summary: Add timeout for test case to avoid Infinite waiting
Key: FLINK-37234
URL: https://issues.apache.org/jira/browse/FLINK-37234
Project: Flink
Issue Type
Hi, Allison. Thanks for driving this FLIP.
I have some questions to confirm:
1. I can’t find any existed configuration name
`historyserver.archive.cached-retained-jobs`, I guess that what you mean is
modifing existing configuration from `historyserver.archive.retained-jobs`
to `historyserver.archi
Yanquan Lv created FLINK-37231:
--
Summary: Add doc for newly added source metric statistics
Key: FLINK-37231
URL: https://issues.apache.org/jira/browse/FLINK-37231
Project: Flink
Issue Type
Yanquan Lv created FLINK-37224:
--
Summary: Add the missing content of MongoDB CDC to the Chinese
document.
Key: FLINK-37224
URL: https://issues.apache.org/jira/browse/FLINK-37224
Project: Flink
Yanquan Lv created FLINK-37223:
--
Summary: Add the missing content of MySQL CDC to the Chinese
document.
Key: FLINK-37223
URL: https://issues.apache.org/jira/browse/FLINK-37223
Project: Flink
Yanquan Lv created FLINK-37210:
--
Summary: Add flink-cdc-release-3.3.0 module to
flink-cdc-migration-tests.
Key: FLINK-37210
URL: https://issues.apache.org/jira/browse/FLINK-37210
Project: Flink
Yanquan Lv created FLINK-37209:
--
Summary: Add Embedding AI Model for Qwen
Key: FLINK-37209
URL: https://issues.apache.org/jira/browse/FLINK-37209
Project: Flink
Issue Type: Improvement
Yanquan Lv created FLINK-37203:
--
Summary: Support AltertableCommentEvent and
AlterColumnCommentEvent.
Key: FLINK-37203
URL: https://issues.apache.org/jira/browse/FLINK-37203
Project: Flink
Yanquan Lv created FLINK-37200:
--
Summary: Add e2e test for ElasticSearch Sink.
Key: FLINK-37200
URL: https://issues.apache.org/jira/browse/FLINK-37200
Project: Flink
Issue Type: Improvement
Yanquan Lv created FLINK-37199:
--
Summary: Update document in quickly start to guide user to add
checkpoint configuration
Key: FLINK-37199
URL: https://issues.apache.org/jira/browse/FLINK-37199
Project
Hi devs,
As FlinkCDC 3.3 was released recently, it's a good time to kick off the
upcoming Flink CDC 3.4 release cycle.
In past community discussions, we have identified the following demands that
need to be completed:
Bump Flink version to 1.20 as it's a long term maintenance version.
Expand
+1 (non-binding)
I checked:
- Verify hashes and verify signatures
- Source code artifacts matching the current release
- Build success from source with JDK8/11 & maven3.8.6
- Review release note in JIRA
- Read the announcement blog and left some comments
Hang Ruan 于 2025年1月18日周六 下午3:25写道：
> Hi e
+1. Thanks for all contributors.
> 2025年1月17日 17:36，Leonard Xu 写道：
>
> Thanks RuanHang for kicking off this discussion, cannot wait this happens, +1
> from my side.
>
>
>
> Best，
> Leonard
>
>> 2025年1月17日 15:38，Hang Ruan 写道：
>>
>> Hi everyone,
>>
>> I want to kick off the discussion for
Yanquan Lv created FLINK-37163:
--
Summary: Add documents for recently merged PRs in FlinkCDC 3.3
Key: FLINK-37163
URL: https://issues.apache.org/jira/browse/FLINK-37163
Project: Flink
Issue Type
Yanquan Lv created FLINK-37162:
--
Summary: Add Data Sources Documentation
Key: FLINK-37162
URL: https://issues.apache.org/jira/browse/FLINK-37162
Project: Flink
Issue Type: Technical Debt
Yanquan Lv created FLINK-37143:
--
Summary: Update version of flink-connector-kafka to 4.0-SNAPSHOT
Key: FLINK-37143
URL: https://issues.apache.org/jira/browse/FLINK-37143
Project: Flink
Issue
Yanquan Lv created FLINK-37144:
--
Summary: Update flink-connector-kafka version to 3.4-SNAPSHOT
Key: FLINK-37144
URL: https://issues.apache.org/jira/browse/FLINK-37144
Project: Flink
Issue Type
Yanquan Lv created FLINK-37142:
--
Summary: Update version of flink-connector-kafka to 4.0-SNAPSHOT
Key: FLINK-37142
URL: https://issues.apache.org/jira/browse/FLINK-37142
Project: Flink
Issue
1 - 100 of 173 matches
Mail list logo
