Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21481#discussion_r194537413
--- Diff:
sql/catalyst/src/main/java/org/apache/spark/sql/catalyst/expressions/VariableLengthRowBasedKeyValueBatch.java
---
@@ -41,7 +41,7 @@
@Override
public UnsafeRow appendRow(Object kbase, long koff, int klen,
Object vbase, long voff, int vlen) {
- final long recordLength = 8 + klen + vlen + 8;
+ final long recordLength = 8L + (long)klen + (long)vlen + 8L;
--- End diff --
ditto
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
