Fixing the wrong type casting of TimeStamp to OTimeStamp when read fr…

…om spark dataFrame. (apache#159) (cherry picked from commit 8ccbfdc)
jamesrgrinter · Jan 2, 2018 · 1e105aa · 1e105aa
1 parent 910e8a8
commit 1e105aa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/external/maprdb/src/main/scala/com/mapr/db/spark/sql/utils/MapRSqlUtils.scala b/external/maprdb/src/main/scala/com/mapr/db/spark/sql/utils/MapRSqlUtils.scala
@@ -403,7 +403,7 @@ object MapRSqlUtils {
       case (BinaryType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(element.asInstanceOf[ByteBuffer])
       case (BooleanType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(element.asInstanceOf[Boolean])
       case (DateType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(new ODate(element.asInstanceOf[java.sql.Date]))
-      case (TimestampType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(element.asInstanceOf[OTimestamp])
+      case (TimestampType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(new OTimestamp(element.asInstanceOf[java.sql.Timestamp].getTime))
       case (NullType) => DBValueBuilderImpl.KeyValueBuilder.initFromNull()
       case (DoubleType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(element.asInstanceOf[Double])
       case (IntegerType) => DBValueBuilderImpl.KeyValueBuilder.initFrom(element.asInstanceOf[Integer])