[hotfix] fix some typos (#1790)

* [hotfix] fix some typos

* add small improvement

---------

Co-authored-by: ipolyzos <[email protected]>

Author: beryllw

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 IllegalConfigurationException(String message) {
     }
 
     /**
-     * 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 IllegalConfigurationException(String format, Object... arguments) {
     }
 
     /**
-     * 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.

fluss-common/src/test/java/org/apache/fluss/utils/IOUtilsTest.java

@@ -49,7 +49,7 @@ void testCopyBytes() throws IOException {
         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);
 

fluss-common/src/test/java/org/apache/fluss/utils/concurrent/ConjunctFutureTest.java

@@ -40,7 +40,7 @@
 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 =

fluss-common/src/test/java/org/apache/fluss/utils/concurrent/ExecutorThreadFactoryTest.java

@@ -26,7 +26,7 @@
 
 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

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/split/SourceSplitBase.java

@@ -25,7 +25,7 @@
 
 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;