This is an automated email from the ASF dual-hosted git repository.
RocMarshal pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new d720d58c3bf [hotfix] Fix some typos for connector-base, protobuf,
runtime, table-planner and tests modules. (#28328)
d720d58c3bf is described below
commit d720d58c3bf2b871eda86851f23b8c7cc1ee55ab
Author: Yuepeng Pan <[email protected]>
AuthorDate: Sun Jun 7 22:48:26 2026 +0800
[hotfix] Fix some typos for connector-base, protobuf, runtime,
table-planner and tests modules. (#28328)
---
.../flink/connector/base/source/hybrid/HybridSourceReader.java | 2 +-
.../flink/formats/protobuf/util/PbSchemaValidationUtils.java | 4 ++--
.../apache/flink/runtime/jobmanager/DefaultApplicationStore.java | 2 +-
.../flink/runtime/jobmanager/DefaultExecutionPlanStore.java | 2 +-
.../apache/flink/table/planner/connectors/DynamicSinkUtils.java | 8 ++++----
.../table/planner/plan/nodes/exec/spec/IntervalJoinSpec.java | 6 +++---
.../flink/test/streaming/runtime/GlobalAggregateITCase.java | 2 +-
7 files changed, 13 insertions(+), 13 deletions(-)
diff --git
a/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java
b/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java
index 02f7017c5a2..64b8313ca80 100644
---
a/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java
+++
b/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java
@@ -223,7 +223,7 @@ public class HybridSourceReader<T> implements
SourceReader<T, HybridSourceSplit>
try {
reader = source.createReader(readerContext);
} catch (Exception e) {
- throw new RuntimeException("Failed tp create reader", e);
+ throw new RuntimeException("Failed to create reader", e);
}
// currentReader must be switched before `addSplits` is called.
currentSourceIndex = index;
diff --git
a/flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util/PbSchemaValidationUtils.java
b/flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util/PbSchemaValidationUtils.java
index 2bb17763854..653dd127ae3 100644
---
a/flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util/PbSchemaValidationUtils.java
+++
b/flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util/PbSchemaValidationUtils.java
@@ -83,7 +83,7 @@ public class PbSchemaValidationUtils {
throw new ValidationException(
"Column "
+ rowField.getName()
- + " does not exists in
definition of proto class.");
+ + " does not exist in
definition of proto class.");
}
});
}
@@ -160,7 +160,7 @@ public class PbSchemaValidationUtils {
throw new ValidationException(
"Protobuf field type does not match column type, "
+ fd.getJavaType()
- + "(protobuf) is not compatible of "
+ + "(protobuf) is not compatible with "
+ logicalTypeRoot);
}
}
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/DefaultApplicationStore.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/DefaultApplicationStore.java
index d332a246ad1..cbb9d52daed 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/DefaultApplicationStore.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/DefaultApplicationStore.java
@@ -210,7 +210,7 @@ public class DefaultApplicationStore<R extends
ResourceVersion<R>> implements Ap
success = true;
} catch (StateHandleStore.NotExistException ignored) {
LOG.warn(
- "{} does not exists in {}.",
+ "{} does not exist in {}.",
application,
applicationStateHandleStore);
}
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/DefaultExecutionPlanStore.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/DefaultExecutionPlanStore.java
index 7ac648c6268..ae58c2722a8 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/DefaultExecutionPlanStore.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/DefaultExecutionPlanStore.java
@@ -235,7 +235,7 @@ public class DefaultExecutionPlanStore<R extends
ResourceVersion<R>>
success = true;
} catch (StateHandleStore.NotExistException ignored) {
LOG.warn(
- "{} does not exists in {}.",
+ "{} does not exist in {}.",
executionPlan,
executionPlanStateHandleStore);
}
diff --git
a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/DynamicSinkUtils.java
b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/DynamicSinkUtils.java
index 219b995864f..860b6131da0 100644
---
a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/DynamicSinkUtils.java
+++
b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/DynamicSinkUtils.java
@@ -515,7 +515,7 @@ public final class DynamicSinkUtils {
&& updateInfo.getRowLevelUpdateMode()
!= SupportsRowLevelUpdate.RowLevelUpdateMode.ALL_ROWS)
{
throw new IllegalArgumentException(
- "Unknown update mode:" +
updateInfo.getRowLevelUpdateMode());
+ "Unknown update mode: " +
updateInfo.getRowLevelUpdateMode());
}
Tuple2<RelNode, int[]> updateRelNodeAndRequireIndices =
convertToRowLevelUpdate(
@@ -647,7 +647,7 @@ public final class DynamicSinkUtils {
if (!(dynamicTableSource instanceof
SupportsReadingMetadata)) {
throw new UnsupportedOperationException(
String.format(
- "The table source don't support
reading metadata, but the require columns contains the meta columns: %s.",
+ "The table source does not support
reading metadata, but the required columns contain metadata columns: %s.",
column));
}
// list what metas the source supports to read
@@ -661,7 +661,7 @@ public final class DynamicSinkUtils {
if (!readableMetadata.containsKey(metaCol)) {
throw new IllegalArgumentException(
String.format(
- "Expect to read the meta column %s,
but the table source for table %s doesn't support read the metadata column."
+ "Expected to read metadata column %s,
but the table source for table %s does not support it. "
+ "Please make sure the
readable metadata for the source contains %s.",
column,
UnresolvedIdentifier.of(
@@ -674,7 +674,7 @@ public final class DynamicSinkUtils {
if (!dataType.equals(column.getDataType())) {
throw new IllegalArgumentException(
String.format(
- "Un-matched data type: the required
column %s has datatype %s, but the data type in readable metadata for the table
%s has data type %s. ",
+ "Mismatched data type: the required
column %s has data type %s, but readable metadata for table %s has data type
%s.",
column,
column.getDataType(),
UnresolvedIdentifier.of(
diff --git
a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/spec/IntervalJoinSpec.java
b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/spec/IntervalJoinSpec.java
index f7075a0a5ec..975a9a396b4 100644
---
a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/spec/IntervalJoinSpec.java
+++
b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/spec/IntervalJoinSpec.java
@@ -28,9 +28,9 @@ import java.util.Objects;
/**
* IntervalJoinSpec describes how two tables will be joined in interval join.
*
- * <p>This class corresponds to {@link org.apache.calcite.rel.core.Join} rel
node. the join
- * condition is splitted into two part: WindowBounds and JoinSpec: 1.
WindowBounds contains the time
- * range condition. 2. JoinSpec contains rest of the join condition except
windowBounds.
+ * <p>This class corresponds to {@link org.apache.calcite.rel.core.Join} rel
node. The join
+ * condition is splitted into two parts: WindowBounds and JoinSpec: 1.
WindowBounds contains the
+ * time range condition. 2. JoinSpec contains rest of the join condition
except windowBounds.
*/
@JsonIgnoreProperties(ignoreUnknown = true)
public class IntervalJoinSpec {
diff --git
a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/GlobalAggregateITCase.java
b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/GlobalAggregateITCase.java
index 9700e4220c4..91fe62079b8 100644
---
a/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/GlobalAggregateITCase.java
+++
b/flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/GlobalAggregateITCase.java
@@ -63,7 +63,7 @@ class GlobalAggregateITCase extends AbstractTestBase {
/**
* Source Function that uses updateGlobalAggregate() functionality exposed
via
* StreamingRuntimeContext to validate communication with JobMaster and
test both failure and
- * sucess scenarios.
+ * success scenarios.
*/
private static class TestSourceFunction extends
RichSourceFunction<Integer> {
