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-spark-connector.git
commit c5bf0b2fd31ff08ce1e819aabc85c744f77bb528 Author: haocean <1727386...@qq.com> 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: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org