This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-kudu.git
commit 78c76c544ab426461e9e4156ebb9ddf561b7b97c Author: Joao Boto <b...@boto.pro> AuthorDate: Thu Mar 23 13:30:24 2023 +0100 [BAHIR-308] Remove scala prefix where we can --- flink-connector-kudu/pom.xml | 14 +++++++++++--- .../kudu/table/dynamic/KuduDynamicTableSource.java | 3 +-- 2 files changed, 12 insertions(+), 5 deletions(-) diff --git a/flink-connector-kudu/pom.xml b/flink-connector-kudu/pom.xml index 134d6f7..8dc4f88 100644 --- a/flink-connector-kudu/pom.xml +++ b/flink-connector-kudu/pom.xml @@ -20,12 +20,12 @@ <parent> <groupId>org.apache.bahir</groupId> - <artifactId>bahir-flink-parent_2.12</artifactId> + <artifactId>bahir-flink-parent</artifactId> <version>1.2-SNAPSHOT</version> <relativePath>../pom.xml</relativePath> </parent> - <artifactId>flink-connector-kudu_2.12</artifactId> + <artifactId>flink-connector-kudu</artifactId> <packaging>jar</packaging> <name>flink-connector-kudu</name> @@ -84,13 +84,21 @@ <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java</artifactId> </dependency> + <dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-table-api-java-bridge</artifactId> + </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-table-common</artifactId> </dependency> <dependency> <groupId>org.apache.flink</groupId> - <artifactId>flink-table-planner_${scala.binary.version}</artifactId> + <artifactId>flink-table-planner-loader</artifactId> + </dependency> + <dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-table-runtime</artifactId> </dependency> <dependency> <groupId>org.apache.kudu</groupId> diff --git a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSource.java b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSource.java index cde6a13..da6bebb 100644 --- a/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSource.java +++ b/flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSource.java @@ -43,7 +43,6 @@ import org.slf4j.LoggerFactory; import java.util.*; -import static org.apache.flink.calcite.shaded.com.google.common.base.Preconditions.checkArgument; import static org.apache.flink.table.utils.TableSchemaUtils.containsPhysicalColumnsOnly; /** @@ -143,7 +142,7 @@ public class KuduDynamicTableSource implements ScanTableSource, SupportsProjecti } private TableSchema projectSchema(TableSchema tableSchema, int[][] projectedFields) { - checkArgument( + Preconditions.checkArgument( containsPhysicalColumnsOnly(tableSchema), "Projection is only supported for physical columns."); TableSchema.Builder builder = TableSchema.builder();