From afe8abfb401c67152d2131057d2482652c9aa2e1 Mon Sep 17 00:00:00 2001 From: wudi <676366545@qq.com> Date: Thu, 26 Sep 2024 18:44:02 +0800 Subject: [PATCH] update --- .../main/java/org/apache/doris/flink/cfg/DorisReadOptions.java | 2 +- .../java/org/apache/doris/flink/source/DorisSourceITCase.java | 3 ++- 2 files changed, 3 insertions(+), 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 index 42cd83a84..937d32866 100644 --- 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 index 7176ad826..6f1483018 100644 --- 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