update

JNSimba · Sep 26, 2024 · afe8abf · afe8abf
1 parent 4fc72ce
commit afe8abf
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java
@@ -187,7 +187,7 @@ public int hashCode() {
                 flightSqlPort);
     }
 
-    public DorisReadOptions copy(){
+    public DorisReadOptions copy() {
         return new DorisReadOptions(
                 readFields,
                 filterQuery,

diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/source/DorisSourceITCase.java
@@ -396,7 +396,8 @@ public void testTableSourceFilterWithUnionAllNotEqualFilter() throws Exception {
         }
 
         String[] expected = new String[] {"+I[flink, 10]", "+I[doris, 18]"};
-        checkResultInAnyOrder("testTableSourceFilterWithUnionAllNotEqualFilter", expected, actual.toArray());
+        checkResultInAnyOrder(
+                "testTableSourceFilterWithUnionAllNotEqualFilter", expected, actual.toArray());
     }
 
     @Test