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-spark-connector.git
The following commit(s) were added to refs/heads/master by this push:
new b7c5464 [fix](connector) fix ut for row convertor and schema
convertor (#278)
b7c5464 is described below
commit b7c54649f825e973716f271244a6243267a02c87
Author: gnehil <[email protected]>
AuthorDate: Mon Mar 10 11:19:14 2025 +0800
[fix](connector) fix ut for row convertor and schema convertor (#278)
---
.../test/scala/org/apache/doris/spark/util/RowConvertorsTest.scala | 2 +-
.../test/scala/org/apache/doris/spark/util/SchemaConvertorsTest.scala | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git
a/spark-doris-connector/spark-doris-connector-base/src/test/scala/org/apache/doris/spark/util/RowConvertorsTest.scala
b/spark-doris-connector/spark-doris-connector-base/src/test/scala/org/apache/doris/spark/util/RowConvertorsTest.scala
index 31a787f..5a08a32 100644
---
a/spark-doris-connector/spark-doris-connector-base/src/test/scala/org/apache/doris/spark/util/RowConvertorsTest.scala
+++
b/spark-doris-connector/spark-doris-connector-base/src/test/scala/org/apache/doris/spark/util/RowConvertorsTest.scala
@@ -113,7 +113,7 @@ class RowConvertorsTest {
Assert.assertTrue(RowConvertors.convertValue(Decimal(BigDecimal(8910.11),
20, 4), DecimalType(20, 4), false).isInstanceOf[Decimal])
Assert.assertTrue(RowConvertors.convertValue(Date.valueOf("2024-01-01"),
DataTypes.DateType, false).isInstanceOf[Int])
Assert.assertTrue(RowConvertors.convertValue(LocalDate.now(),
DataTypes.DateType, true).isInstanceOf[Int])
- Assert.assertTrue(RowConvertors.convertValue("2024-01-01 12:34:56",
DataTypes.TimestampType, false).isInstanceOf[Long])
+ Assert.assertTrue(RowConvertors.convertValue(Timestamp.valueOf("2024-01-01
12:34:56"), DataTypes.TimestampType, false).isInstanceOf[Long])
val map = new util.HashMap[String, String]()
map.put("a", "1")
Assert.assertTrue(RowConvertors.convertValue(map,
MapType(DataTypes.StringType, DataTypes.StringType),
false).isInstanceOf[MapData])
diff --git
a/spark-doris-connector/spark-doris-connector-base/src/test/scala/org/apache/doris/spark/util/SchemaConvertorsTest.scala
b/spark-doris-connector/spark-doris-connector-base/src/test/scala/org/apache/doris/spark/util/SchemaConvertorsTest.scala
index 6f92ece..b259bc1 100644
---
a/spark-doris-connector/spark-doris-connector-base/src/test/scala/org/apache/doris/spark/util/SchemaConvertorsTest.scala
+++
b/spark-doris-connector/spark-doris-connector-base/src/test/scala/org/apache/doris/spark/util/SchemaConvertorsTest.scala
@@ -37,8 +37,8 @@ class SchemaConvertorsTest {
Assert.assertEquals(SchemaConvertors.toCatalystType("DOUBLE", -1, -1),
DataTypes.DoubleType)
Assert.assertEquals(SchemaConvertors.toCatalystType("DATE", -1, -1),
DataTypes.DateType)
Assert.assertEquals(SchemaConvertors.toCatalystType("DATEV2", -1, -1),
DataTypes.DateType)
- Assert.assertEquals(SchemaConvertors.toCatalystType("DATETIME", -1, -1),
DataTypes.StringType)
- Assert.assertEquals(SchemaConvertors.toCatalystType("DATETIMEV2", -1, -1),
DataTypes.StringType)
+ Assert.assertEquals(SchemaConvertors.toCatalystType("DATETIME", -1, -1),
DataTypes.TimestampType)
+ Assert.assertEquals(SchemaConvertors.toCatalystType("DATETIMEV2", -1, -1),
DataTypes.TimestampType)
Assert.assertEquals(SchemaConvertors.toCatalystType("BINARY", -1, -1),
DataTypes.BinaryType)
Assert.assertEquals(SchemaConvertors.toCatalystType("DECIMAL", 20, 4),
DecimalType(20, 4))
Assert.assertEquals(SchemaConvertors.toCatalystType("CHAR", -1, -1),
DataTypes.StringType)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
