Skip to content

Commit 7f00198

Browse files
committed
fix compile
1 parent eff1790 commit 7f00198

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/UnsafeFixedWidthAggregationMapSuite.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@ import scala.util.control.NonFatal
2626
import org.scalatest.Matchers
2727

2828
import org.apache.spark.{SparkConf, SparkFunSuite, TaskContext, TaskContextImpl}
29+
import org.apache.spark.executor.TaskMetrics
2930
import org.apache.spark.memory.{TaskMemoryManager, TestMemoryManager}
3031
import org.apache.spark.sql.catalyst.InternalRow
3132
import org.apache.spark.sql.catalyst.expressions.UnsafeRow
@@ -74,7 +75,8 @@ class UnsafeFixedWidthAggregationMapSuite
7475
attemptNumber = 0,
7576
taskMemoryManager = taskMemoryManager,
7677
localProperties = new Properties,
77-
metricsSystem = null))
78+
metricsSystem = null,
79+
taskMetrics = new TaskMetrics))
7880

7981
try {
8082
f

sql/core/src/test/scala/org/apache/spark/sql/execution/UnsafeKVExternalSorterSuite.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ import java.util.Properties
2222
import scala.util.Random
2323

2424
import org.apache.spark._
25+
import org.apache.spark.executor.TaskMetrics
2526
import org.apache.spark.memory.{TaskMemoryManager, TestMemoryManager}
2627
import org.apache.spark.sql.{RandomDataGenerator, Row}
2728
import org.apache.spark.sql.catalyst.{CatalystTypeConverters, InternalRow}
@@ -120,7 +121,8 @@ class UnsafeKVExternalSorterSuite extends SparkFunSuite with SharedSQLContext {
120121
attemptNumber = 0,
121122
taskMemoryManager = taskMemMgr,
122123
localProperties = new Properties,
123-
metricsSystem = null))
124+
metricsSystem = null,
125+
taskMetrics = new TaskMetrics))
124126

125127
val sorter = new UnsafeKVExternalSorter(
126128
keySchema, valueSchema, SparkEnv.get.blockManager, SparkEnv.get.serializerManager, pageSize)

0 commit comments

Comments
 (0)