This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new f92bc754 [Fix] unsupport when use doris catalog list views (#432)
f92bc754 is described below
commit f92bc7541448f1a946567f00bf06d915a2e65ad7
Author: wudi <[email protected]>
AuthorDate: Wed Jul 17 15:52:12 2024 +0800
[Fix] unsupport when use doris catalog list views (#432)
---
.../src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java | 4 ++--
.../src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java | 2 ++
.../src/main/java/org/apache/doris/flink/catalog/doris/DorisType.java | 2 ++
3 files changed, 6 insertions(+), 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
index c56f64a0..a6e92158 100644
---
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 class DorisCatalog extends AbstractCatalog {
@Override
public List<String> listViews(String databaseName)
throws DatabaseNotExistException, CatalogException {
- throw new UnsupportedOperationException();
+ return Collections.emptyList();
}
@Override
@@ -425,7 +425,7 @@ public class DorisCatalog extends AbstractCatalog {
@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
index a8e3d7d6..bfca184e 100644
---
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 org.apache.doris.flink.catalog.doris.DorisType;
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 class DorisTypeMapper {
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
index b2b3776c..7bc9fd0b 100644
---
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";
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
