Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/19230#discussion_r139287815
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/ColumnVectorUtils.java
---
@@ -158,7 +158,7 @@ private static void appendValue(WritableColumnVector
dst, DataType t, Object o)
dst.getChildColumn(0).appendInt(c.months);
dst.getChildColumn(1).appendLong(c.microseconds);
} else if (t instanceof DateType) {
- dst.appendInt(DateTimeUtils.fromJavaDate((Date)o));
+ dst.appendInt((int) DateTimeUtils.fromJavaDate((Date)o));
--- End diff --
is it necessary?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
