This is an automated email from the ASF dual-hosted git repository.
kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 37783004a [minor][docs][style] Update documentation link and improve
code style (#3961)
37783004a is described below
commit 37783004a1650f11badd36ae7e55c1144d503294
Author: chenhongyu <[email protected]>
AuthorDate: Mon Mar 9 13:59:49 2026 +0800
[minor][docs][style] Update documentation link and improve code style
(#3961)
---
.../connectors/elasticsearch/sink/ElasticsearchDataSinkFactory.java | 2 +-
.../flink/cdc/connectors/mysql/source/MySqlEventDeserializer.java | 5 ++---
.../cdc/connectors/starrocks/sink/StarRocksDataSinkOptions.java | 4 ++--
3 files changed, 5 insertions(+), 6 deletions(-)
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkFactory.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkFactory.java
index 83f7c1152..14229dcc3 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkFactory.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkFactory.java
@@ -73,7 +73,7 @@ public class ElasticsearchDataSinkFactory implements
DataSinkFactory {
ZoneId zoneId = determineZoneId(context);
ElasticsearchSinkOptions sinkOptions =
buildSinkConnectorOptions(configuration);
- return new ElasticsearchDataSink(sinkOptions, zoneId);
+ return new ElasticsearchDataSink<>(sinkOptions, zoneId);
}
private ZoneId determineZoneId(Context context) {
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlEventDeserializer.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlEventDeserializer.java
index 80b44dc29..cce2258a3 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlEventDeserializer.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlEventDeserializer.java
@@ -70,8 +70,8 @@ public class MySqlEventDeserializer extends
DebeziumEventDeserializationSchema {
private transient Tables tables;
private transient CustomMySqlAntlrDdlParser customParser;
- private List<MySqlReadableMetadata> readableMetadataList;
- private boolean isTableIdCaseInsensitive;
+ private final List<MySqlReadableMetadata> readableMetadataList;
+ private final boolean isTableIdCaseInsensitive;
public MySqlEventDeserializer(
DebeziumChangelogMode changelogMode,
@@ -85,7 +85,6 @@ public class MySqlEventDeserializer extends
DebeziumEventDeserializationSchema {
includeSchemaChanges,
tinyInt1isBit,
isTableIdCaseInsensitive);
- this.isTableIdCaseInsensitive = isTableIdCaseInsensitive;
}
public MySqlEventDeserializer(
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSinkOptions.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSinkOptions.java
index 5f8220602..5f7b7d8ab 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSinkOptions.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSinkOptions.java
@@ -136,8 +136,8 @@ public class StarRocksDataSinkOptions {
/**
* The prefix for properties used for creating a table. You can refer to
StarRocks documentation
- * for the DDL.
- *
https://docs.starrocks.io/docs/table_design/table_types/primary_key_table/#create-a-table
+ * for the DDL. <a
+ *
href="https://docs.starrocks.io/docs/table_design/table_types/primary_key_table/#create-primary-key-table";>create-primary-key-table</a>
*/
public static final String TABLE_CREATE_PROPERTIES_PREFIX =
"table.create.properties.";
