-
Notifications
You must be signed in to change notification settings - Fork 2k
Pull requests: apache/flink-cdc
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[FLINK-36931][cdc] FlinkCDC YAML supports batch mode
common
composer
values-pipeline-connector
#3812
opened Dec 23, 2024 by
aiwenmo
Loading…
[FLINK-36580][pipeline-connector-mysql] Fix column.[in|ex]clude.list parameter causing schema inconsistency
e2e-tests
mysql-cdc-connector
mysql-pipeline-connector
#3810
opened Dec 20, 2024 by
MOBIN-F
Loading…
[hotfix][postgres] Flink CDC Postgres Connector subsribe regular expr…
postgres-cdc-connector
#3808
opened Dec 19, 2024 by
hql0312
Loading…
[FLINK-36913][pipeline-connector][kafka] Add sink.table.mapping option to allow user to define a custom map for upstream TableId to downstream topic name.
docs
Improvements or additions to documentation
kafka-pipeline-connector
reviewed
#3805
opened Dec 17, 2024 by
lvyanquan
Loading…
[FLINK-36701][cdc-runtime] Add steps to get and emit schemaManager's latest evolvedSchema when SinkDataWriterOperator handles FlushEvent
common
runtime
#3802
opened Dec 13, 2024 by
Jzjsnow
Loading…
[FLINK-36811][mysql] MySQL cdc setIsProcessingBacklog in snapshot phase and exit when snapshot phase finished
mysql-cdc-connector
#3793
opened Dec 11, 2024 by
Shawn-Hx
Loading…
[FLINK-36877][pipeline-connector-kafka] Fix the output of canal-json for Kafka Sink when the record is deleted record.
approved
kafka-pipeline-connector
reviewed
#3788
opened Dec 10, 2024 by
lvyanquan
Loading…
[FLINK-36858][pipeline-connector][kafka] Fix compatibility with Flink 1.20 JsonRowDataSerializationSchema
e2e-tests
kafka-pipeline-connector
reviewed
#3784
opened Dec 9, 2024 by
MOBIN-F
Loading…
[FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions
docs
Improvements or additions to documentation
mysql-cdc-connector
mysql-pipeline-connector
#3776
opened Dec 4, 2024 by
uicosp
Loading…
[FLINK-36842] FlinkPipelineComposer allows injecting StreamExecutionEnvironment
composer
#3775
opened Dec 3, 2024 by
maxf-decodable
Loading…
[docs] Cleanup pipeline example / remove 'will soon' from reference to transform support
docs
Improvements or additions to documentation
#3772
opened Dec 2, 2024 by
rmoff
Loading…
[FLINK-36827] CDC quickstart tidyup
docs
Improvements or additions to documentation
#3771
opened Dec 2, 2024 by
rmoff
Loading…
[UDF]udf dateformat support LocalZonedTimestampData
runtime
#3770
opened Nov 29, 2024 by
hiliuxg
Loading…
[CliFrontend]support overwrite flink config by command line
cli
#3769
opened Nov 29, 2024 by
hiliuxg
Loading…
[FLINK-36813][cdc-connectors][mysql] support mysql sync part columns
mysql-cdc-connector
#3767
opened Nov 28, 2024 by
JNSimba
Loading…
[FLINK-36790][cdc-connector][paimon] set waitCompaction with true dur…
approved
paimon-pipeline-connector
reviewed
#3760
opened Nov 26, 2024 by
stayrascal
Loading…
[FLINK-36785][cdc][starrocks] Improve Starrocks unsupported field error return value
starrocks-pipeline-connector
#3757
opened Nov 25, 2024 by
hunter-cloud09
Loading…
[FLINK-36754][transform] when projection is empty or null, it is treated as an asterisk
composer
runtime
#3749
opened Nov 21, 2024 by
MOBIN-F
Loading…
[FLINK-35490] Migrate tests to JUnit 5 and AssertJ
base
build
cli
common
composer
connector-test-util
db2-cdc-connector
doris-pipeline-connector
e2e-tests
elasticsearch-pipeline-connector
kafka-pipeline-connector
migration-tests
mongodb-cdc-connector
mysql-cdc-connector
mysql-pipeline-connector
oceanbase-cdc-connector
oracle-cdc-connector
paimon-pipeline-connector
postgres-cdc-connector
runtime
sqlserver-cdc-connector
starrocks-pipeline-connector
tidb-cdc-connector
values-pipeline-connector
vitess-cdc-connector
#3742
opened Nov 19, 2024 by
yuxiqian
Loading…
[FLINK-36741][cdc][transform] Fix the precision of decimal has been lost when use transform
composer
reviewed
runtime
values-pipeline-connector
#3740
opened Nov 18, 2024 by
aiwenmo
Loading…
[FLINK-36742][cdc-base][oracle] Filter unacked split for no capture tables when task restore from state
base
oracle-cdc-connector
#3739
opened Nov 18, 2024 by
gong
Loading…
Previous Next
ProTip!
Mix and match filters to narrow down what you’re looking for.