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 <[email protected]> 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;
