[Fix] unsupport when use doris catalog list views (apache#432)

JNSimba · Jul 17, 2024 · f92bc75 · f92bc75
1 parent 13f1fcd
commit f92bc75
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 2 deletions.
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java
@@ -202,7 +202,7 @@ public List<String> listTables(String databaseName)
     @Override
     public List<String> listViews(String databaseName)
             throws DatabaseNotExistException, CatalogException {
-        throw new UnsupportedOperationException();
+        return Collections.emptyList();
     }
 
     @Override
@@ -425,7 +425,7 @@ public CatalogPartition getPartition(ObjectPath tablePath, CatalogPartitionSpec
     @Override
     public boolean partitionExists(ObjectPath tablePath, CatalogPartitionSpec partitionSpec)
             throws CatalogException {
-        throw new UnsupportedOperationException();
+        return false;
     }
 
     @Override

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java
@@ -47,6 +47,7 @@
 
 import static org.apache.doris.flink.catalog.doris.DorisType.ARRAY;
 import static org.apache.doris.flink.catalog.doris.DorisType.BIGINT;
+import static org.apache.doris.flink.catalog.doris.DorisType.BIGINT_UNSIGNED;
 import static org.apache.doris.flink.catalog.doris.DorisType.BOOLEAN;
 import static org.apache.doris.flink.catalog.doris.DorisType.CHAR;
 import static org.apache.doris.flink.catalog.doris.DorisType.DATE;
@@ -113,6 +114,7 @@ public static DataType toFlinkType(
             case VARCHAR:
                 return DataTypes.VARCHAR(precision);
             case LARGEINT:
+            case BIGINT_UNSIGNED:
             case STRING:
             case JSONB:
             case JSON:

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisType.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisType.java
@@ -24,6 +24,8 @@ public class DorisType {
     public static final String INT = "INT";
     public static final String BIGINT = "BIGINT";
     public static final String LARGEINT = "LARGEINT";
+    // largeint is bigint unsigned in information_schema.COLUMNS
+    public static final String BIGINT_UNSIGNED = "BIGINT UNSIGNED";
     public static final String FLOAT = "FLOAT";
     public static final String DOUBLE = "DOUBLE";
     public static final String DECIMAL = "DECIMAL";