This is an automated email from the ASF dual-hosted git repository.
yux 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 ef5777a94 [FLINK-39063][connect/fluss] Fix some spelling mistakes in
fluss pipeline connector (#4271)
ef5777a94 is described below
commit ef5777a94a26423c62e75f7177e6af4779cdea38
Author: Thorne <[email protected]>
AuthorDate: Wed Feb 11 18:54:30 2026 +0800
[FLINK-39063][connect/fluss] Fix some spelling mistakes in fluss pipeline
connector (#4271)
---
.../cdc/connectors/fluss/sink/FlussEventSerializationSchema.java | 6 +++---
.../flink/cdc/connectors/fluss/sink/FlussMetaDataApplier.java | 6 +++---
.../metrics/{WarppedFlussCounter.java => WrappedFlussCounter.java} | 4 ++--
.../fluss/sink/v2/metrics/WrapperFlussMetricRegistry.java | 2 +-
.../flink/cdc/connectors/fluss/sink/FlussMetadataApplierTest.java | 2 +-
5 files changed, 10 insertions(+), 10 deletions(-)
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussEventSerializationSchema.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussEventSerializationSchema.java
index d946916b6..e92557b11 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussEventSerializationSchema.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussEventSerializationSchema.java
@@ -145,14 +145,14 @@ public class FlussEventSerializationSchema implements
FlussEventSerializer<Event
static Map<Integer, Integer> sanityCheckAndGenerateIndexMapping(
com.alibaba.fluss.metadata.Schema inferredFlussSchema,
- com.alibaba.fluss.metadata.Schema currentFlussnewSchema) {
+ com.alibaba.fluss.metadata.Schema currentFlussNewSchema) {
List<String> inferredSchemaColumnNames =
inferredFlussSchema.getColumnNames();
Map<String, Integer> reverseIndex = new HashMap<>();
for (int i = 0; i < inferredSchemaColumnNames.size(); i++) {
reverseIndex.put(inferredSchemaColumnNames.get(i), i);
}
- List<String> currentSchemaColumnNames =
currentFlussnewSchema.getColumnNames();
+ List<String> currentSchemaColumnNames =
currentFlussNewSchema.getColumnNames();
Map<Integer, Integer> indexMapping = new HashMap<>();
for (int newSchemaIndex = 0;
newSchemaIndex < currentSchemaColumnNames.size();
@@ -167,7 +167,7 @@ public class FlussEventSerializationSchema implements
FlussEventSerializer<Event
// changes.
// In the future, meta applier will be used to handle column
changes.
DataType oldDataType =
inferredFlussSchema.getRowType().getTypeAt(oldSchemaIndex);
- DataType newDataType =
currentFlussnewSchema.getRowType().getTypeAt(newSchemaIndex);
+ DataType newDataType =
currentFlussNewSchema.getRowType().getTypeAt(newSchemaIndex);
if (!oldDataType.copy(false).equals(newDataType.copy(false))) {
throw new IllegalArgumentException(
"The data type of column "
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussMetaDataApplier.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussMetaDataApplier.java
index 9ab7a6f78..5ce51447e 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussMetaDataApplier.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/FlussMetaDataApplier.java
@@ -149,7 +149,7 @@ public class FlussMetaDataApplier implements
MetadataApplier {
.collect(Collectors.toList());
if
(!inferredPrimaryKeyColumnNames.equals(currentPrimaryKeyColumnNames)) {
throw new ValidationException(
- "The table schema inffered by Flink CDC is not matched
with current Fluss table schema. "
+ "The table schema inferred by Flink CDC is not matched
with current Fluss table schema. "
+ "\n New Fluss table's primary keys : "
+ inferredPrimaryKeyColumnNames
+ "\n Current Fluss's primary keys: "
@@ -160,7 +160,7 @@ public class FlussMetaDataApplier implements
MetadataApplier {
List<String> currentBucketKeys = currentTableInfo.getBucketKeys();
if (!inferredBucketKeys.equals(currentBucketKeys)) {
throw new ValidationException(
- "The table schema inffered by Flink CDC is not matched
with current Fluss table schema. "
+ "The table schema inferred by Flink CDC is not matched
with current Fluss table schema. "
+ "\n New Fluss table's bucket keys : "
+ inferredBucketKeys
+ "\n Current Fluss's bucket keys: "
@@ -171,7 +171,7 @@ public class FlussMetaDataApplier implements
MetadataApplier {
List<String> currentPartitionKeys =
currentTableInfo.getPartitionKeys();
if (!inferredPartitionKeys.equals(currentPartitionKeys)) {
throw new ValidationException(
- "The table schema inffered by Flink CDC is not matched
with current Fluss table schema. "
+ "The table schema inferred by Flink CDC is not matched
with current Fluss table schema. "
+ "\n New Fluss table's partition keys : "
+ inferredPartitionKeys
+ "\n Current Fluss's partition keys: "
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WarppedFlussCounter.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrappedFlussCounter.java
similarity index 93%
rename from
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WarppedFlussCounter.java
rename to
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrappedFlussCounter.java
index 8f3c1e3d6..61bcff7b0 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WarppedFlussCounter.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrappedFlussCounter.java
@@ -24,11 +24,11 @@ import org.apache.flink.metrics.Counter;
* additional information regarding copyright ownership. */
/** An implementation of Flink's {@link Counter} which wraps Fluss's Counter.
*/
-public class WarppedFlussCounter implements Counter {
+public class WrappedFlussCounter implements Counter {
private final com.alibaba.fluss.metrics.Counter flussCounter;
- public WarppedFlussCounter(com.alibaba.fluss.metrics.Counter flussCounter)
{
+ public WrappedFlussCounter(com.alibaba.fluss.metrics.Counter flussCounter)
{
this.flussCounter = flussCounter;
}
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrapperFlussMetricRegistry.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrapperFlussMetricRegistry.java
index 6b33202ef..4251a71d6 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrapperFlussMetricRegistry.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/sink/v2/metrics/WrapperFlussMetricRegistry.java
@@ -116,7 +116,7 @@ public class WrapperFlussMetricRegistry implements
MetricRegistry {
private void registerMetric(MetricGroup metricGroup, Metric metric, String
metricName) {
switch (metric.getMetricType()) {
case COUNTER:
- metricGroup.counter(metricName, new
WarppedFlussCounter((Counter) metric));
+ metricGroup.counter(metricName, new
WrappedFlussCounter((Counter) metric));
break;
case METER:
metricGroup.meter(metricName, new WrapperFlussMeter((Meter)
metric));
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/test/java/org/apache/flink/cdc/connectors/fluss/sink/FlussMetadataApplierTest.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/test/java/org/apache/flink/cdc/connectors/fluss/sink/FlussMetadataApplierTest.java
index 69e26bd59..9c35f002d 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/test/java/org/apache/flink/cdc/connectors/fluss/sink/FlussMetadataApplierTest.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/test/java/org/apache/flink/cdc/connectors/fluss/sink/FlussMetadataApplierTest.java
@@ -511,7 +511,7 @@ public class FlussMetadataApplierTest {
applier.applySchemaChange(
new CreateTableEvent(tableId,
differentSchema)))
.hasMessageContaining(
- "The table schema inffered by Flink CDC is not
matched with current Fluss table schema");
+ "The table schema inferred by Flink CDC is not
matched with current Fluss table schema");
}
// recreate table with schema1 again
