| commit | 792ea9973d37fc4ecf6e4a7a3a29380462044d47 | [log] [tgz] |
|---|---|---|
| author | LB Yu <44154062+LB-Yu@users.noreply.github.com> | Fri Apr 03 03:52:48 2020 +0800 |
| committer | GitHub <noreply@github.com> | Thu Apr 02 21:52:48 2020 +0200 |
| tree | c667d5c2111f7d0a2b31447bb0d2e3f36e08e0c7 | |
| parent | 423fa92f1b7c201b1b469bc71f146bbb2f547883 [diff] |
HBASE-24088 Solve the ambiguous reference for scala 2.12 (#63) Signed-off-by: Balazs Meszaros <meszibalu@apache.org>
diff --git a/spark/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/datasources/HBaseTableScanRDD.scala b/spark/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/datasources/HBaseTableScanRDD.scala index 6c06811..346983c 100644 --- a/spark/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/datasources/HBaseTableScanRDD.scala +++ b/spark/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/datasources/HBaseTableScanRDD.scala
@@ -213,7 +213,7 @@ val scans = partition.scanRanges .map(buildScan(_, filter, columns)) val tableResource = TableResource(relation) - context.addTaskCompletionListener(context => close()) + context.addTaskCompletionListener[Unit](context => close()) val points = partition.points val gIt: Iterator[Result] = { if (points.isEmpty) {