[bahir-flink] 08/16: fix: reformat code style

[es...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

eskabetxe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bahir-flink.git

commit 987b0d8e161854af4fb83fc9b08f1eebd60e11a1
Author: min <40...@users.noreply.github.com>
AuthorDate: Thu May 19 19:33:56 2022 +0800

    fix: reformat code style
---
 .../java/org/apache/flink/connectors/kudu/table/KuduTableFactory.java  | 3 +--
 .../flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java       | 2 +-
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableFactory.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableFactory.java
index 9bdeb5d..9112b0a 100644
--- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableFactory.java
+++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableFactory.java
@@ -14,14 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package org.apache.flink.connectors.kudu.table;
 
 import org.apache.flink.api.java.tuple.Tuple2;
 import org.apache.flink.connectors.kudu.connector.KuduTableInfo;
 import org.apache.flink.connectors.kudu.connector.reader.KuduReaderConfig;
 import org.apache.flink.connectors.kudu.connector.writer.KuduWriterConfig;
-import org.apache.flink.connectors.kudu.table.function.lookup.KuduLookupOptions;
 import org.apache.flink.connectors.kudu.table.utils.KuduTableUtils;
 import org.apache.flink.table.api.TableSchema;
 import org.apache.flink.table.catalog.CatalogTable;
@@ -73,6 +71,7 @@ public class KuduTableFactory implements TableSourceFactory<Row>, TableSinkFacto
     public static final String KUDU_IGNORE_NOT_FOUND = "kudu.ignore-not-found";
     public static final String KUDU_IGNORE_DUPLICATE = "kudu.ignore-duplicate";
     public static final String KUDU = "kudu";
+
     @Override
     public Map<String, String> requiredContext() {
         Map<String, String> context = new HashMap<>();
diff --git a/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java b/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java
index 80f60cf..8dd1a79 100644
--- a/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java
+++ b/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java
@@ -33,7 +33,7 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
  * Unit Tests for {@link KuduDynamicTableSink}.
  */
 public class KuduDynamicSinkTest extends KuduTestBase {
-    public final static String INPUT_TABLE = "books";
+    public static final String INPUT_TABLE = "books";
     public static StreamExecutionEnvironment env;
     public static TableEnvironment tEnv;