Skip to content

Commit ffb8b14

Browse files
jinkachyThorneANN
authored andcommitted
[minor][docs][style] Update documentation link and improve code style (apache#3961)
1 parent 2e40f04 commit ffb8b14

3 files changed

Lines changed: 5 additions & 6 deletions

File tree

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ public DataSink createDataSink(Context context) {
7373

7474
ZoneId zoneId = determineZoneId(context);
7575
ElasticsearchSinkOptions sinkOptions = buildSinkConnectorOptions(configuration);
76-
return new ElasticsearchDataSink(sinkOptions, zoneId);
76+
return new ElasticsearchDataSink<>(sinkOptions, zoneId);
7777
}
7878

7979
private ZoneId determineZoneId(Context context) {

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlEventDeserializer.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -70,8 +70,8 @@ public class MySqlEventDeserializer extends DebeziumEventDeserializationSchema {
7070
private transient Tables tables;
7171
private transient CustomMySqlAntlrDdlParser customParser;
7272

73-
private List<MySqlReadableMetadata> readableMetadataList;
74-
private boolean isTableIdCaseInsensitive;
73+
private final List<MySqlReadableMetadata> readableMetadataList;
74+
private final boolean isTableIdCaseInsensitive;
7575

7676
public MySqlEventDeserializer(
7777
DebeziumChangelogMode changelogMode,
@@ -85,7 +85,6 @@ public MySqlEventDeserializer(
8585
includeSchemaChanges,
8686
tinyInt1isBit,
8787
isTableIdCaseInsensitive);
88-
this.isTableIdCaseInsensitive = isTableIdCaseInsensitive;
8988
}
9089

9190
public MySqlEventDeserializer(

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSinkOptions.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -136,8 +136,8 @@ public class StarRocksDataSinkOptions {
136136

137137
/**
138138
* The prefix for properties used for creating a table. You can refer to StarRocks documentation
139-
* for the DDL.
140-
* https://docs.starrocks.io/docs/table_design/table_types/primary_key_table/#create-a-table
139+
* for the DDL. <a
140+
* href="https://docs.starrocks.io/docs/table_design/table_types/primary_key_table/#create-primary-key-table">create-primary-key-table</a>
141141
*/
142142
public static final String TABLE_CREATE_PROPERTIES_PREFIX = "table.create.properties.";
143143

0 commit comments

Comments
 (0)