This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris-connectors.git
The following commit(s) were added to refs/heads/master by this push:
new 8fdc9f4 [fix](spark connector) fix spark connector unsupport STRING
type. (#2)
8fdc9f4 is described below
commit 8fdc9f44b8cd4387e2bbaf1829096ef9522f94a1
Author: haocean <[email protected]>
AuthorDate: Thu Feb 10 22:43:09 2022 +0800
[fix](spark connector) fix spark connector unsupport STRING type. (#2)
fix spark connector unsupported STRING type.
---
.../src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala | 1 +
.../src/test/scala/org/apache/doris/spark/sql/TestSchemaUtils.scala | 1 +
2 files changed, 2 insertions(+)
diff --git
a/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala
b/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala
index f595092..f45b9de 100644
---
a/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala
+++
b/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala
@@ -89,6 +89,7 @@ private[spark] object SchemaUtils {
case "VARCHAR" => DataTypes.StringType
case "DECIMALV2" => DecimalType(precision, scale)
case "TIME" => DataTypes.DoubleType
+ case "STRING" => DataTypes.StringType
case "HLL" =>
throw new DorisException("Unsupported type " + dorisType)
case _ =>
diff --git
a/spark-doris-connector/src/test/scala/org/apache/doris/spark/sql/TestSchemaUtils.scala
b/spark-doris-connector/src/test/scala/org/apache/doris/spark/sql/TestSchemaUtils.scala
index 97bbe0e..13004b4 100644
---
a/spark-doris-connector/src/test/scala/org/apache/doris/spark/sql/TestSchemaUtils.scala
+++
b/spark-doris-connector/src/test/scala/org/apache/doris/spark/sql/TestSchemaUtils.scala
@@ -62,6 +62,7 @@ class TestSchemaUtils extends ExpectedExceptionTest {
Assert.assertEquals(DataTypes.StringType,
SchemaUtils.getCatalystType("VARCHAR", 0, 0))
Assert.assertEquals(DecimalType(10, 5),
SchemaUtils.getCatalystType("DECIMALV2", 10, 5))
Assert.assertEquals(DataTypes.DoubleType,
SchemaUtils.getCatalystType("TIME", 0, 0))
+ Assert.assertEquals(DataTypes.StringType,
SchemaUtils.getCatalystType("STRING", 0, 0))
thrown.expect(classOf[DorisException])
thrown.expectMessage(startsWith("Unsupported type"))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
