[
https://issues.apache.org/jira/browse/FLINK-39327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daishuyuan updated FLINK-39327:
-------------------------------
Description:
The current dws pipeline connector supports syncing Flink CDC data changes
into GaussDB DWS, including INSERT, UPDATE, and DELETE, and also supports basic
schema
evolution such as table creation, column add/drop/type change/rename, table
truncate, and table drop. It also provides configurable write mode, auto flush,
time zone, and
distribution-key related options.
was:
The existing pipeline sink connector is currently exposed as
{code}gaussdws{code} in the module name, package name, service registration,
and factory identifier.
However, the underlying dependency and connector runtime already use DWS:
* Maven dependency: {code}com.huaweicloud.dws:dws-connector-flink{code}
* connector classes already use the {code}Dws*{code} naming
This naming is inconsistent and can be confusing for users, especially in
pipeline YAML where the sink type is currently {code}gaussdws{code}.
This issue proposes to rename the connector consistently from
{code}gaussdws{code} to {code}dws{code}.
Scope:
* rename module {code}flink-cdc-pipeline-connector-gaussdws{code} to
{code}flink-cdc-pipeline-connector-dws{code}
* rename Java packages and classes from
{code}org.apache.flink.cdc.connectors.gaussdws.*{code} to
{code}org.apache.flink.cdc.connectors.dws.*{code}
* rename the factory identifier from {code}gaussdws{code} to {code}dws{code}
* update service loader registration
* update related tests and pipeline YAML examples
The change is mainly a naming cleanup and should not introduce new sink
behavior.
Issue Type: New Feature (was: Improvement)
Summary: gauss dws pipeline sink connector (was: Rename gaussdws
pipeline sink connector to dws)
> gauss dws pipeline sink connector
> ---------------------------------
>
> Key: FLINK-39327
> URL: https://issues.apache.org/jira/browse/FLINK-39327
> Project: Flink
> Issue Type: New Feature
> Components: Flink CDC
> Reporter: Daishuyuan
> Priority: Minor
>
> The current dws pipeline connector supports syncing Flink CDC data changes
> into GaussDB DWS, including INSERT, UPDATE, and DELETE, and also supports
> basic schema
> evolution such as table creation, column add/drop/type change/rename, table
> truncate, and table drop. It also provides configurable write mode, auto
> flush, time zone, and
> distribution-key related options.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
