Skip to content

Pull requests: apache/flink-cdc

New pull request New
96 Open 1,558 Closed
96 Open 1,558 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[FLINK-37012][transform] Fix exception caused by metadataColumns causing argument type mismatch runtime
#3837 opened Jan 6, 2025 by MOBIN-F Loading…
2
[FLINK-37011] Improve get source field value by column name in PreTra… common runtime
#3836 opened Jan 6, 2025 by ChaomingZhangCN Loading…
修改FlinkDeployment的jarURI地址错误的问题 docs Improvements or additions to documentation
#3835 opened Jan 6, 2025 by liuxuzxx Loading…
1
[FLINK-37000] Fix MySQL CDC could not handle datetime prior to 1970 properly mysql-cdc-connector mysql-pipeline-connector
#3834 opened Jan 3, 2025 by yuxiqian Loading…
[FLINK-36999][cdc-source-connectors] When the source type is oracle and field type is nember and the value is null, a null pointer exception occurs during deserialization.
#3833 opened Jan 3, 2025 by linjianchang Loading…
1
[docs] Add missing enumeration mysql-pipeline-connector
#3832 opened Jan 3, 2025 by ChaomingZhangCN Loading…
[FLINK-36958][pipeline-connector][kafka] Support csv/json/debezium-json/canal-json format options common kafka-pipeline-connector
#3830 opened Jan 2, 2025 by MOBIN-F Loading…
1
[FLINK-36805][cdc-common] Add ConfigShade interface to support encryption of sensitive configuration items and provide a base64 encoding implementation cli common
#3829 opened Jan 2, 2025 by Jzjsnow Loading…
[FLINK-36985]remove Catalog.ColumnAlreadyExistException when apply applyAddColumnEventWithPosition in paimon paimon-pipeline-connector
#3828 opened Jan 1, 2025 by hiliuxg Loading…
1
[FLINK-36981][cdc] Fix the bug of transform merging with route in YAML task composer runtime
#3826 opened Dec 30, 2024 by aiwenmo Loading…
4
[FLINK-36978]Fix the bug where the command-line option from-savepoint is invalid in K8s deployment mode. cli
#3825 opened Dec 28, 2024 by hiliuxg Loading…
[FLINK-36977]paimon apply default value options when apply add_column schema change paimon-pipeline-connector
#3824 opened Dec 28, 2024 by hiliuxg Loading…
2
[FLINK-36974]support overwrite flink config by command line cli
#3823 opened Dec 28, 2024 by hiliuxg Loading…
6
[FLINK-36973]udf dateformat support LocalZonedTimestampData runtime
#3822 opened Dec 28, 2024 by hiliuxg Loading…
[FLINK-36970][runtime] Merge result of data type BIGINT and DOUBLE should be DOUBLE instead of STRING common
#3821 opened Dec 27, 2024 by Shawn-Hx Loading…
1
[FLINK-36967] [cdc-connector] [paimon] Bump dependency of Paimon Pipeline connector to 0.9.0 docs Improvements or additions to documentation paimon-pipeline-connector
#3820 opened Dec 27, 2024 by yangjf2019 Loading…
1
[FLINK-36865][cdc] Provide UNIX_TIMESTAMP series functions in YAML pipeline common docs Improvements or additions to documentation runtime
#3819 opened Dec 26, 2024 by aiwenmo Loading…
10
[FLINK-36964] Fix potential exception when SchemaChange in parallel w… common paimon-pipeline-connector
#3818 opened Dec 26, 2024 by lvyanquan • Draft
2
[FLINK-36956][transform] Append NOT NULL attribute to PK columns composer docs Improvements or additions to documentation reviewed runtime
#3815 opened Dec 25, 2024 by yuxiqian Loading…
2
[FLINK-36931][cdc] FlinkCDC YAML supports batch mode common composer mysql-pipeline-connector runtime values-pipeline-connector
#3812 opened Dec 23, 2024 by aiwenmo Loading…
3
[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…
6
[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…
12
[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…
9
[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…
ProTip! no:milestone will show everything without a milestone.