diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkUtilities.java ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkUtilities.java index 6ac72ce..705c079 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkUtilities.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkUtilities.java @@ -17,6 +17,7 @@ */ package org.apache.hadoop.hive.ql.exec.spark; +import org.apache.hadoop.io.BinaryComparable; import org.apache.hadoop.io.BytesWritable; import org.apache.hadoop.mapred.JobConf; import org.apache.spark.TaskContext; @@ -26,9 +27,9 @@ */ public class SparkUtilities { - public static BytesWritable copyBytesWritable(BytesWritable bw) { + public static BytesWritable copyBytesWritable(BinaryComparable bw) { BytesWritable copy = new BytesWritable(); - copy.set(bw); + copy.set(bw.getBytes(), 0, bw.getLength()); return copy; }