Congratulations!
Best,
Zakelly
On Thu, Mar 21, 2024 at 12:05 PM weijie guo
wrote:
> Congratulations! Well done.
>
>
> Best regards,
>
> Weijie
>
>
> Feng Jin 于2024年3月21日周四 11:40写道：
>
>> Congratulations!
>>
>>
>> Best,
>> Feng
>>
>>
>> On Thu, Mar 21, 2024 at 11:37 AM Ron liu wrote:
>>
>> > C
Congratulations! Well done.
Best regards,
Weijie
Feng Jin 于2024年3月21日周四 11:40写道：
> Congratulations!
>
>
> Best,
> Feng
>
>
> On Thu, Mar 21, 2024 at 11:37 AM Ron liu wrote:
>
> > Congratulations!
> >
> > Best,
> > Ron
> >
> > Jark Wu 于2024年3月21日周四 10:46写道：
> >
> > > Congratulations and wel
Weijie Guo created FLINK-34900:
--
Summary: Check compatibility for classes in flink-core-api that
skip japicmp
Key: FLINK-34900
URL: https://issues.apache.org/jira/browse/FLINK-34900
Project: Flink
Weijie Guo created FLINK-34899:
--
Summary: Remove all classes that skip the japicmp check for
flink-core-api
Key: FLINK-34899
URL: https://issues.apache.org/jira/browse/FLINK-34899
Project: Flink
Congratulations!
Best,
Feng
On Thu, Mar 21, 2024 at 11:37 AM Ron liu wrote:
> Congratulations!
>
> Best,
> Ron
>
> Jark Wu 于2024年3月21日周四 10:46写道：
>
> > Congratulations and welcome!
> >
> > Best,
> > Jark
> >
> > On Thu, 21 Mar 2024 at 10:35, Rui Fan <1996fan...@gmail.com> wrote:
> >
> > > Co
Congratulations!
Best,
Ron
Jark Wu 于2024年3月21日周四 10:46写道：
> Congratulations and welcome!
>
> Best,
> Jark
>
> On Thu, 21 Mar 2024 at 10:35, Rui Fan <1996fan...@gmail.com> wrote:
>
> > Congratulations!
> >
> > Best,
> > Rui
> >
> > On Thu, Mar 21, 2024 at 10:25 AM Hang Ruan
> wrote:
> >
> > > C
Congratulations!
Best,
Jacky Lau
Hongshun Wang 于2024年3月21日周四 10:32写道：
> Congratulations!
>
> Best,
> Hongshun
>
> On Tue, Mar 19, 2024 at 3:12 PM Shawn Huang wrote:
>
> > Congratulations!
> >
> > Best,
> > Shawn Huang
> >
> >
> > Xuannan Su 于2024年3月19日周二 14:40写道：
> >
> > > Congratulations! Th
Hi Ron and Lincoln
Thanks for driving this discussion. I believe it will greatly improve the
convenience of managing user real-time pipelines.
I have some questions.
*Regarding Limitations of Dynamic Table:*
> Does not support modifying the select statement after the dynamic table
is created.
Congratulations and welcome!
Best,
Jark
On Thu, 21 Mar 2024 at 10:35, Rui Fan <1996fan...@gmail.com> wrote:
> Congratulations!
>
> Best,
> Rui
>
> On Thu, Mar 21, 2024 at 10:25 AM Hang Ruan wrote:
>
> > Congrattulations!
> >
> > Best,
> > Hang
> >
> > Lincoln Lee 于2024年3月21日周四 09:54写道：
> >
> >
Cheers!
--
Best！
Xuyang
在 2024-03-21 10:28:45，"Rui Fan" <1996fan...@gmail.com> 写道：
>Congratulations!
>
>Best,
>Rui
>
>On Thu, Mar 21, 2024 at 10:25 AM Hang Ruan wrote:
>
>> Congrattulations!
>>
>> Best,
>> Hang
>>
>> Lincoln Lee 于2024年3月21日周四 09:54写道：
>>
>>>
>>> Congrats, thanks for
Congratulations. Thanks to Qingsheng for driving this job forward.
Best,
Hongshun
On Wed, Mar 20, 2024 at 9:08 PM Qingsheng Ren wrote:
> FYI: The auto-import has completed. Totally 137 issues are migrated from
> GitHub issue to Apache Jira. Sorry again for flushing your inbox!
>
> Best,
> Qings
Congratulations!
Best,
Rui
On Thu, Mar 21, 2024 at 10:25 AM Hang Ruan wrote:
> Congrattulations!
>
> Best,
> Hang
>
> Lincoln Lee 于2024年3月21日周四 09:54写道：
>
>>
>> Congrats, thanks for the great work!
>>
>>
>> Best,
>> Lincoln Lee
>>
>>
>> Peter Huang 于2024年3月20日周三 22:48写道：
>>
>>> Congratulation
+1(binding)
Thanks to Weijie for driving this proposal, which solves the problem that I
raised in FLIP-359.
Best,
Rui
On Thu, Mar 21, 2024 at 10:10 AM Hangxiang Yu wrote:
> +1 (binding)
>
> On Thu, Mar 21, 2024 at 10:04 AM Xintong Song
> wrote:
>
> > +1 (binding)
> >
> > Best,
> >
> > Xintong
Congratulations!
Best,
Hongshun
On Tue, Mar 19, 2024 at 3:12 PM Shawn Huang wrote:
> Congratulations!
>
> Best,
> Shawn Huang
>
>
> Xuannan Su 于2024年3月19日周二 14:40写道：
>
> > Congratulations! Thanks for all the great work!
> >
> > Best regards,
> > Xuannan
> >
> > On Tue, Mar 19, 2024 at 1:31 PM
Congratulations! Thanks to all contributors.
Best,
Yanquan
Shawn Huang 于2024年3月19日周二 15:12写道：
> Congratulations!
>
> Best,
> Shawn Huang
>
>
> Xuannan Su 于2024年3月19日周二 14:40写道：
>
> > Congratulations! Thanks for all the great work!
> >
> > Best regards,
> > Xuannan
> >
> > On Tue, Mar 19, 2024
Congrattulations!
Best,
Hang
Lincoln Lee 于2024年3月21日周四 09:54写道：
>
> Congrats, thanks for the great work!
>
>
> Best,
> Lincoln Lee
>
>
> Peter Huang 于2024年3月20日周三 22:48写道：
>
>> Congratulations
>>
>>
>> Best Regards
>> Peter Huang
>>
>> On Wed, Mar 20, 2024 at 6:56 AM Huajie Wang wrote:
>>
>>>
+1 (binding)
On Thu, Mar 21, 2024 at 10:04 AM Xintong Song wrote:
> +1 (binding)
>
> Best,
>
> Xintong
>
>
>
> On Wed, Mar 20, 2024 at 8:30 PM weijie guo
> wrote:
>
> > Hi everyone,
> >
> >
> > Thanks for all the feedback about the FLIP-433: State Access on
> > DataStream API V2 [1]. The discus
+1 (binding)
Best,
Xintong
On Wed, Mar 20, 2024 at 8:30 PM weijie guo
wrote:
> Hi everyone,
>
>
> Thanks for all the feedback about the FLIP-433: State Access on
> DataStream API V2 [1]. The discussion thread is here [2].
>
>
> The vote will be open for at least 72 hours unless there is an
>
Chloe He created FLINK-34898:
Summary: Cannot create named STRUCT with a single field
Key: FLINK-34898
URL: https://issues.apache.org/jira/browse/FLINK-34898
Project: Flink
Issue Type: Bug
Congrats, thanks for the great work!
Best,
Lincoln Lee
Peter Huang 于2024年3月20日周三 22:48写道：
> Congratulations
>
>
> Best Regards
> Peter Huang
>
> On Wed, Mar 20, 2024 at 6:56 AM Huajie Wang wrote:
>
>>
>> Congratulations
>>
>>
>>
>> Best,
>> Huajie Wang
>>
>>
>>
>> Leonard Xu 于2024年3月20日周三 2
Hi,
+1 (non-binding)
- Verified checksums
- Verified signatures
- Verified no binaries in source distribution
- Verified Apache License and NOTICE files
- Executed tests
- Built container image
- Verified chart version and appVersion matches
- Verified Helm chart can be installed with default val
Sorry for the late reply Kevin.
I think what you are suggesting makes sense, it would be basically a
`last-state` startup mode. This would also help in cases where the current
last-state mechanism fails to locate HA metadata (and the state).
This is somewhat of a tricky feature to implement:
1.
Hi Asimansu,
Thanks for chiming in!
Yes, this is pretty much what we’re trying to accomplish, a few notes:
- With 2 instances constantly running is hard to control who writes to the sink
and when (only the active one should), we can only write to 1 sink and don’t
want duplicates records going
Thanks Jark for all the insightful comments.
We have updated the proposal per our offline discussions:
1. Model will be treated as a new relation in FlinkSQL.
2. Include the common ML predict and evaluate functions into the open
source flink to complete the user journey.
And we should be able
+1 (binding)
On Wed, Mar 20, 2024 at 8:37 AM Gabor Somogyi
wrote:
> +1 (binding)
>
> G
>
>
> On Wed, Mar 20, 2024 at 3:59 PM Gyula Fóra wrote:
>
> > +1 (binding)
> >
> > Thanks!
> > Gyula
> >
> > On Wed, Mar 20, 2024 at 3:36 PM Mate Czagany wrote:
> >
> > > +1 (non-binding)
> > >
> > > Thank y
+1 (binding)
G
On Wed, Mar 20, 2024 at 3:59 PM Gyula Fóra wrote:
> +1 (binding)
>
> Thanks!
> Gyula
>
> On Wed, Mar 20, 2024 at 3:36 PM Mate Czagany wrote:
>
> > +1 (non-binding)
> >
> > Thank you,
> > Mate
> >
> > Ferenc Csaky ezt írta (időpont: 2024. márc.
> > 20., Sze, 15:11):
> >
> > > H
Thank you very much for your feedback Mark. I have made the changes in the
latest google document. On reflection I agree with you that the
globalIdPlacement format configuration should apply to the deserialization as
well, so it is declarative. I am also going to have a new configuration option
+1 to this
A few small comments:
Currently, if users have Avro schemas in an Apicurio Registry (an open source
Apache 2 licensed schema registry), then the natural way to work with those
Avro flows is to use the schemas in the Apicurio Repository.
'those Avro flows' ... this is the first refer
+1 (binding)
Thanks!
Gyula
On Wed, Mar 20, 2024 at 3:36 PM Mate Czagany wrote:
> +1 (non-binding)
>
> Thank you,
> Mate
>
> Ferenc Csaky ezt írta (időpont: 2024. márc.
> 20., Sze, 15:11):
>
> > Hello devs,
> >
> > I would like to start a vote about FLIP-439 [1]. The FLIP is about to
> > extern
Matthias Pohl created FLINK-34897:
-
Summary:
JobMasterServiceLeadershipRunnerTest#testJobMasterServiceLeadershipRunnerCloseWhenElectionServiceGrantLeaderShip
needs to be enabled again
Key: FLINK-34897
URL: https:
Congratulations
Best Regards
Peter Huang
On Wed, Mar 20, 2024 at 6:56 AM Huajie Wang wrote:
>
> Congratulations
>
>
>
> Best,
> Huajie Wang
>
>
>
> Leonard Xu 于2024年3月20日周三 21:36写道：
>
>> Hi devs and users,
>>
>> We are thrilled to announce that the donation of Flink CDC as a
>> sub-project of
+1 (non-binding)
Thank you,
Mate
Ferenc Csaky ezt írta (időpont: 2024. márc.
20., Sze, 15:11):
> Hello devs,
>
> I would like to start a vote about FLIP-439 [1]. The FLIP is about to
> externalize the Kudu
> connector from the recently retired Apache Bahir project [2] to keep it
> maintainable
Hello devs,
I would like to start a vote about FLIP-439 [1]. The FLIP is about to
externalize the Kudu
connector from the recently retired Apache Bahir project [2] to keep it
maintainable and
make it up to date as well. Discussion thread [3].
The vote will be open for at least 72 hours (until 2
Hey Zakelly!
Sorry for the late reply. I still have concerns about the proposed
solution, with my main concerns coming from
the implications of the asynchronous state access API on the checkpointing
and responsiveness of Flink.
>> What also worries me a lot in this fine grained model is the effec
Congratulations
Best,
Huajie Wang
Leonard Xu 于2024年3月20日周三 21:36写道：
> Hi devs and users,
>
> We are thrilled to announce that the donation of Flink CDC as a
> sub-project of Apache Flink has completed. We invite you to explore the new
> resources available:
>
> - GitHub Repository: https://
Hi devs and users,
We are thrilled to announce that the donation of Flink CDC as a sub-project of
Apache Flink has completed. We invite you to explore the new resources
available:
- GitHub Repository: https://github.com/apache/flink-cdc
- Flink CDC Documentation:
https://nightlies.apache.org/f
+1 (non-binding), thanks for driving this!
Best,
Ferenc
On Wednesday, March 20th, 2024 at 10:57, Yang Wang
wrote:
>
>
> +1 (binding) since ZK HA is still widely used.
>
>
> Best,
> Yang
>
> On Thu, Mar 14, 2024 at 6:27 PM Matthias Pohl
> matthias.p...@aiven.io.invalid wrote:
>
> > Nothi
Sergey Nuyanzin created FLINK-34896:
---
Summary: Mi
Key: FLINK-34896
URL: https://issues.apache.org/jira/browse/FLINK-34896
Project: Flink
Issue Type: Sub-task
Reporter: Sergey Nu
FYI: The auto-import has completed. Totally 137 issues are migrated from
GitHub issue to Apache Jira. Sorry again for flushing your inbox!
Best,
Qingsheng
On Wed, Mar 20, 2024 at 3:47 PM Qingsheng Ren wrote:
> Hi devs,
>
> We are in the process of finalizing the donation of Flink CDC as a
> sub
Sergey Nuyanzin created FLINK-34895:
---
Summary: Migrate FlinkRewriteSubQueryRule
Key: FLINK-34895
URL: https://issues.apache.org/jira/browse/FLINK-34895
Project: Flink
Issue Type: Sub-task
Hi Yue,
Thanks for your comments.
I get your point.I think there are two possible ways we can support
multiGet in synchronization models in future:
1) Implement the multiGet interface in the existing Rocksdb State
interface, then integrate this interface to the synchronous Operators layer.
2) Inte
Hi Yue,
Thanks for your feedback!
> 1. If we choose Option-3 for ForSt , how would we handle Manifest File
> ? Should we take a snapshot of the Manifest during the synchronization
phase?
IIUC, the GetLiveFiles() API in Option-3 can also catch the fileInfo of
Manifest files, and this api also ret
Sergey Nuyanzin created FLINK-34894:
---
Summary: Migrate JoinDependentConditionDerivationRule
Key: FLINK-34894
URL: https://issues.apache.org/jira/browse/FLINK-34894
Project: Flink
Issue Type
Sergey Nuyanzin created FLINK-34893:
---
Summary: Bump Checkstyle to 9+
Key: FLINK-34893
URL: https://issues.apache.org/jira/browse/FLINK-34893
Project: Flink
Issue Type: Bug
Compone
Hi everyone,
Thanks for all the feedback about the FLIP-433: State Access on
DataStream API V2 [1]. The discussion thread is here [2].
The vote will be open for at least 72 hours unless there is an
objection or insufficient votes.
Best regards,
Weijie
[1]
https://cwiki.apache.org/confluenc
Using a separate CR for managing the savepoints is really a good idea.
After then managing savepoints will be easier and we will not leak any
unusable savepoints on the object storage.
Best,
Yang
On Wed, Mar 13, 2024 at 4:40 AM Gyula Fóra wrote:
> That would be great Mate! If you could draw up
Flink CDC Issue Import created FLINK-34890:
--
Summary:
io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource
:.java.sql.SQLException: ORA-01291: missing log file
Key: FLINK-34890
URL: h
Flink CDC Issue Import created FLINK-34888:
--
Summary: How to do MySQL to MySQL pipeline
Key: FLINK-34888
URL: https://issues.apache.org/jira/browse/FLINK-34888
Project: Flink
Issue
Flink CDC Issue Import created FLINK-34889:
--
Summary: Flink CDC may occur binlog can't be find when dynamic
added table repeatedly
Key: FLINK-34889
URL: https://issues.apache.org/jira/browse/FLINK-34889
Flink CDC Issue Import created FLINK-34855:
--
Summary: [Improve] When using miniCluster, don't check
'FLINK_HOME'.
Key: FLINK-34855
URL: https://issues.apache.org/jira/browse/FLINK-34855
Proj
Flink CDC Issue Import created FLINK-34883:
--
Summary: Error on Postgres-CDC using incremental snapshot with
UUID column as PK
Key: FLINK-34883
URL: https://issues.apache.org/jira/browse/FLINK-34883
Flink CDC Issue Import created FLINK-34871:
--
Summary: Oracle add data has error
Key: FLINK-34871
URL: https://issues.apache.org/jira/browse/FLINK-34871
Project: Flink
Issue Type: Bug
Flink CDC Issue Import created FLINK-34862:
--
Summary: [Bug] oracle-cdc ORA-01371: Complete LogMiner dictionary
not found
Key: FLINK-34862
URL: https://issues.apache.org/jira/browse/FLINK-34862
Flink CDC Issue Import created FLINK-34869:
--
Summary: [Bug][mysql] Remove all previous table and add new added
table will throw Exception.
Key: FLINK-34869
URL: https://issues.apache.org/jira/browse/FLINK
Flink CDC Issue Import created FLINK-34832:
--
Summary: [Bug] BinlogOffset's comparative method may be cause
incremental snapshot scan data lose
Key: FLINK-34832
URL: https://issues.apache.org/jira/browse/F
Hi,
As per the FLIP process I would like to raise a FLIP, but do not have
authority, so have created a google doc for the Flip to introduce a new
Apicurio Avro format. The document is
https://docs.google.com/document/d/14LWZPVFQ7F9mryJPdKXb4l32n7B0iWYkcOdEd1xTC7w/edit?usp=sharing
I have prototy
Flink CDC Issue Import created FLINK-34878:
--
Summary: [Feature][Pipeline] Flink CDC pipeline transform supports
CASE WHEN
Key: FLINK-34878
URL: https://issues.apache.org/jira/browse/FLINK-34878
Flink CDC Issue Import created FLINK-34874:
--
Summary: [MongoDB] Support initial.snapshotting.pipeline related
configs in table api
Key: FLINK-34874
URL: https://issues.apache.org/jira/browse/FLINK-34874
Flink CDC Issue Import created FLINK-34866:
--
Summary: [Bug] Meet NoClassDefFoundError when add new table in
mysql cdc source
Key: FLINK-34866
URL: https://issues.apache.org/jira/browse/FLINK-34866
Flink CDC Issue Import created FLINK-34825:
--
Summary: [flink-cdc-pipeline-connectors] Add Implementation of
DataSource in MongoDB
Key: FLINK-34825
URL: https://issues.apache.org/jira/browse/FLINK-34825
Flink CDC Issue Import created FLINK-34828:
--
Summary: sql server Limited date synchronization
Key: FLINK-34828
URL: https://issues.apache.org/jira/browse/FLINK-34828
Project: Flink
I
Flink CDC Issue Import created FLINK-34850:
--
Summary: [test] Support to execute the (mysql) test cases with
custom database deployment
Key: FLINK-34850
URL: https://issues.apache.org/jira/browse/FLINK-348
Flink CDC Issue Import created FLINK-34856:
--
Summary: [Bug] timeout when Invocating Remote RPC.
Key: FLINK-34856
URL: https://issues.apache.org/jira/browse/FLINK-34856
Project: Flink
Flink CDC Issue Import created FLINK-34860:
--
Summary: [Bug] Jackson version conflicts among MySQL/TiDB/MongoDB
connectors
Key: FLINK-34860
URL: https://issues.apache.org/jira/browse/FLINK-34860
Flink CDC Issue Import created FLINK-34861:
--
Summary: [Bug] Inconsistent Kafka shading among cdc connectors
Key: FLINK-34861
URL: https://issues.apache.org/jira/browse/FLINK-34861
Project: Fli
Flink CDC Issue Import created FLINK-34849:
--
Summary: Flink CDC3.0 Demo Mysql binlog to Starrocks Exception
amount of AddColumnEvent is already existed[Bug]
Key: FLINK-34849
URL: https://issues.apache.or
Flink CDC Issue Import created FLINK-34875:
--
Summary: [Feature] CDC Action supports update and delete record
(logical deletion)
Key: FLINK-34875
URL: https://issues.apache.org/jira/browse/FLINK-34875
Flink CDC Issue Import created FLINK-34844:
--
Summary: [3.1][pipeline-connectors] Add pipeline Sink for Pulsar.
Key: FLINK-34844
URL: https://issues.apache.org/jira/browse/FLINK-34844
Project:
Flink CDC Issue Import created FLINK-34873:
--
Summary: [Bug] After starting Streaming ELT from MySQL to
StarRocks using Flink CDC 3.0, the newly created tables are not being
synchronized.
Key: FLINK-34873
Flink CDC Issue Import created FLINK-34809:
--
Summary: [mysql] Add notifications to Slack when the Snapshot
phase ends or Binlog stream phase begins
Key: FLINK-34809
URL: https://issues.apache.org/jira/bro
Flink CDC Issue Import created FLINK-34812:
--
Summary: [Bug] During the snapshot phase, projection is not being
performed according to the user defined schema.
Key: FLINK-34812
URL: https://issues.apache.o
Flink CDC Issue Import created FLINK-34830:
--
Summary: [3.1][cdc-composer] verify the options of Context for
Factory.
Key: FLINK-34830
URL: https://issues.apache.org/jira/browse/FLINK-34830
Pr
Flink CDC Issue Import created FLINK-34886:
--
Summary: Support Sybase database
Key: FLINK-34886
URL: https://issues.apache.org/jira/browse/FLINK-34886
Project: Flink
Issue Type: Bug
Flink CDC Issue Import created FLINK-34868:
--
Summary: [Bug] oracle-cdc cannot read oracle multitenant pdb
binlog: ORA-00942: table or view does not exist (LOG_MINING_FLUSH)
Key: FLINK-34868
URL: https://i
Flink CDC Issue Import created FLINK-34829:
--
Summary: When will opengauss or gaussdb be supported?
Key: FLINK-34829
URL: https://issues.apache.org/jira/browse/FLINK-34829
Project: Flink
Flink CDC Issue Import created FLINK-34843:
--
Summary: [Bug] BinlogSplitReader#pollSplitRecords return
finishedSplit when exception occurs
Key: FLINK-34843
URL: https://issues.apache.org/jira/browse/FLINK-
Flink CDC Issue Import created FLINK-34811:
--
Summary: [Bug] [sqlserver cdc] the field "snapshot" is always
"false"
Key: FLINK-34811
URL: https://issues.apache.org/jira/browse/FLINK-34811
Pr
Flink CDC Issue Import created FLINK-34835:
--
Summary: [cdc-common] Add default value of pipeline parallelism.
Key: FLINK-34835
URL: https://issues.apache.org/jira/browse/FLINK-34835
Project: F
Flink CDC Issue Import created FLINK-34822:
--
Summary: [Bug] oracle clob
Key: FLINK-34822
URL: https://issues.apache.org/jira/browse/FLINK-34822
Project: Flink
Issue Type: Bug
Flink CDC Issue Import created FLINK-34806:
--
Summary: [Feature][Postgres] Support automatically identify newly
added tables
Key: FLINK-34806
URL: https://issues.apache.org/jira/browse/FLINK-34806
Flink CDC Issue Import created FLINK-34877:
--
Summary: [Feature][Pipeline] Flink CDC pipeline transform supports
type conversion
Key: FLINK-34877
URL: https://issues.apache.org/jira/browse/FLINK-34877
Flink CDC Issue Import created FLINK-34839:
--
Summary: Flink CDC 3.1.0 Plan
Key: FLINK-34839
URL: https://issues.apache.org/jira/browse/FLINK-34839
Project: Flink
Issue Type: Improvem
Aleksandr Pilipenko created FLINK-34892:
---
Summary: Nightly AWS connectors build fails on running python tests
Key: FLINK-34892
URL: https://issues.apache.org/jira/browse/FLINK-34892
Project: Flin
Flink CDC Issue Import created FLINK-34880:
--
Summary: [Feature][Pipeline] SchemeRegistry saves the routing
rules used to restore the TransformDataOperator
Key: FLINK-34880
URL: https://issues.apache.org/j
Flink CDC Issue Import created FLINK-34859:
--
Summary: [Bug] Oracle cdc in table api does no support
server-time-zone option
Key: FLINK-34859
URL: https://issues.apache.org/jira/browse/FLINK-34859
Flink CDC Issue Import created FLINK-34798:
--
Summary: [Bug] flink cdc mysql, use datastream to synchronize
multiple tables, read full amount of data in a loop
Key: FLINK-34798
URL: https://issues.apache.o
Flink CDC Issue Import created FLINK-34876:
--
Summary: [Feature][Pipeline] Flink CDC pipeline transform supports
UDF
Key: FLINK-34876
URL: https://issues.apache.org/jira/browse/FLINK-34876
Pro
Flink CDC Issue Import created FLINK-34848:
--
Summary: refactor: some class in flink-connector-mysql-cdc do not
inherit from the base class in flink-cdc-base
Key: FLINK-34848
URL: https://issues.apache.org
Flink CDC Issue Import created FLINK-34853:
--
Summary: [Feature] submit Flink CDC pipeline job to k8s cluster.
Key: FLINK-34853
URL: https://issues.apache.org/jira/browse/FLINK-34853
Project: F
Flink CDC Issue Import created FLINK-34867:
--
Summary: [Bug] [StarRocks] [cdc master branch] Unsupported CDC
data type BYTES/VARBINARY
Key: FLINK-34867
URL: https://issues.apache.org/jira/browse/FLINK-3486
Flink CDC Issue Import created FLINK-34864:
--
Summary: [enhancement] [ cdc-connector] [ignore no primary key
table] When using regular expressions to synchronize the entire database with
Flink CDC, skip tables that do not have a primary k
Flink CDC Issue Import created FLINK-34882:
--
Summary: mysql cdc to doris: TIME type converting fail
Key: FLINK-34882
URL: https://issues.apache.org/jira/browse/FLINK-34882
Project: Flink
Flink CDC Issue Import created FLINK-34885:
--
Summary: mysql to sr pipeline， float value bug
Key: FLINK-34885
URL: https://issues.apache.org/jira/browse/FLINK-34885
Project: Flink
Flink CDC Issue Import created FLINK-34881:
--
Summary: [Feature] Flink CDC Oracle support tables without primary
keys and scan newly added tables
Key: FLINK-34881
URL: https://issues.apache.org/jira/browse
Flink CDC Issue Import created FLINK-34879:
--
Summary: [Feature][Pipeline] Flink CDC pipeline transform supports
the strategy of schema evolution
Key: FLINK-34879
URL: https://issues.apache.org/jira/browse
Hi Balint,
Excellent, I have just put up a discussion thread on the dev list for a new Fli
top add this, please review and feedback and +1 if this is what you are looking
for.
At the moment, I have not got the topic name in there. I wonder where we would
use the topic name during deserialization
Flink CDC Issue Import created FLINK-34870:
--
Summary: [Bug] MongoCDC checkpoint error
Key: FLINK-34870
URL: https://issues.apache.org/jira/browse/FLINK-34870
Project: Flink
Issue Typ
Flink CDC Issue Import created FLINK-34865:
--
Summary: [enhancement] [StarRocks] When synchronizing tables using
Flink CDC 3.x, is it possible to include the comments of the source table's
fields when creating the target table?
+1 (binding) since ZK HA is still widely used.
Best,
Yang
On Thu, Mar 14, 2024 at 6:27 PM Matthias Pohl
wrote:
> Nothing to add from my side. Thanks, Alex.
>
> +1 (binding)
>
> On Thu, Mar 7, 2024 at 4:09 PM Alex Nitavsky
> wrote:
>
> > Hi everyone,
> >
> > I'd like to start a vote on FLIP-40
Flink CDC Issue Import created FLINK-34814:
--
Summary: [Bug] java.lang.NoClassDefFoundError: Could not
initialize class org.apache.kafka.connect.json.JsonConverterConfig
Key: FLINK-34814
URL: https://issue
1 - 100 of 193 matches
Mail list logo
