This is an automated email from the ASF dual-hosted git repository.
ipolyzos pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
The following commit(s) were added to refs/heads/main by this push:
new 665e4e8cf [hotfix] fix some typos (#1790)
665e4e8cf is described below
commit 665e4e8cf1f270276cb747eed262ee72991db31a
Author: Junbo Wang <[email protected]>
AuthorDate: Mon Oct 13 01:29:23 2025 +0800
[hotfix] fix some typos (#1790)
* [hotfix] fix some typos
* add small improvement
---------
Co-authored-by: ipolyzos <[email protected]>
---
.../org/apache/fluss/exception/IllegalConfigurationException.java | 6 +++---
fluss-common/src/test/java/org/apache/fluss/utils/IOUtilsTest.java | 2 +-
.../java/org/apache/fluss/utils/concurrent/ConjunctFutureTest.java | 2 +-
.../apache/fluss/utils/concurrent/ExecutorThreadFactoryTest.java | 2 +-
.../java/org/apache/fluss/flink/source/split/SourceSplitBase.java | 2 +-
5 files changed, 7 insertions(+), 7 deletions(-)
diff --git
a/fluss-common/src/main/java/org/apache/fluss/exception/IllegalConfigurationException.java
b/fluss-common/src/main/java/org/apache/fluss/exception/IllegalConfigurationException.java
index fd52edc17..f574f2771 100644
---
a/fluss-common/src/main/java/org/apache/fluss/exception/IllegalConfigurationException.java
+++
b/fluss-common/src/main/java/org/apache/fluss/exception/IllegalConfigurationException.java
@@ -33,7 +33,7 @@ public class IllegalConfigurationException extends
RuntimeException {
private static final long serialVersionUID = 695506964810499989L;
/**
- * Constructs an new IllegalConfigurationException with the given error
message.
+ * Constructs a new IllegalConfigurationException with the given error
message.
*
* @param message The error message for the exception.
*/
@@ -42,7 +42,7 @@ public class IllegalConfigurationException extends
RuntimeException {
}
/**
- * Constructs an new IllegalConfigurationException with the given error
message format and
+ * Constructs a new IllegalConfigurationException with the given error
message format and
* arguments.
*
* @param format The error message format for the exception.
@@ -53,7 +53,7 @@ public class IllegalConfigurationException extends
RuntimeException {
}
/**
- * Constructs an new IllegalConfigurationException with the given error
message and a given
+ * Constructs a new IllegalConfigurationException with the given error
message and a given
* cause.
*
* @param message The error message for the exception.
diff --git a/fluss-common/src/test/java/org/apache/fluss/utils/IOUtilsTest.java
b/fluss-common/src/test/java/org/apache/fluss/utils/IOUtilsTest.java
index c478baa73..6279a1a61 100644
--- a/fluss-common/src/test/java/org/apache/fluss/utils/IOUtilsTest.java
+++ b/fluss-common/src/test/java/org/apache/fluss/utils/IOUtilsTest.java
@@ -49,7 +49,7 @@ class IOUtilsTest {
ByteArrayOutputStream copyOut = new ByteArrayOutputStream();
// copy bytes to a output stream
IOUtils.copyBytes(in, copyOut);
- // then, read bytes from the out out stream
+ // then, read bytes from the output stream
byte[] buf = new byte[5];
IOUtils.readFully(new ByteArrayInputStream(out.toByteArray()), buf, 0,
5);
diff --git
a/fluss-common/src/test/java/org/apache/fluss/utils/concurrent/ConjunctFutureTest.java
b/fluss-common/src/test/java/org/apache/fluss/utils/concurrent/ConjunctFutureTest.java
index 603eecd9a..ec8160031 100644
---
a/fluss-common/src/test/java/org/apache/fluss/utils/concurrent/ConjunctFutureTest.java
+++
b/fluss-common/src/test/java/org/apache/fluss/utils/concurrent/ConjunctFutureTest.java
@@ -40,7 +40,7 @@ import java.util.stream.IntStream;
import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
-/** Tests for the {@link ConjunctFuture} and its sub classes. */
+/** Tests for the {@link ConjunctFuture} and its subclasses. */
@ExtendWith(ParameterizedTestExtension.class)
public class ConjunctFutureTest {
private static final List<FutureFactory> PARAMETERS =
diff --git
a/fluss-common/src/test/java/org/apache/fluss/utils/concurrent/ExecutorThreadFactoryTest.java
b/fluss-common/src/test/java/org/apache/fluss/utils/concurrent/ExecutorThreadFactoryTest.java
index d4c5d1ad5..52d67c0dc 100644
---
a/fluss-common/src/test/java/org/apache/fluss/utils/concurrent/ExecutorThreadFactoryTest.java
+++
b/fluss-common/src/test/java/org/apache/fluss/utils/concurrent/ExecutorThreadFactoryTest.java
@@ -26,7 +26,7 @@ import java.util.concurrent.TimeUnit;
import static org.assertj.core.api.Assertions.assertThat;
-/** Test for {@link org.apache.fluss.utils.concurrent.ExecutorThreadFactory}.
. */
+/** Test for {@link org.apache.fluss.utils.concurrent.ExecutorThreadFactory}.
*/
public class ExecutorThreadFactoryTest {
@Test
diff --git
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/split/SourceSplitBase.java
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/split/SourceSplitBase.java
index ebdce07ab..6240b4fea 100644
---
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/split/SourceSplitBase.java
+++
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/split/SourceSplitBase.java
@@ -25,7 +25,7 @@ import javax.annotation.Nullable;
import java.util.Objects;
-/** A base source split for {@link SnapshotSplit} and {@link LogSplit}. . */
+/** A base source split for {@link SnapshotSplit} and {@link LogSplit}. */
public abstract class SourceSplitBase implements SourceSplit {
public static final byte HYBRID_SNAPSHOT_SPLIT_FLAG = 1;
