File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
core/src/test/scala/org/apache/spark/executor Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -42,7 +42,7 @@ import org.apache.spark.metrics.MetricsSystem
4242import org .apache .spark .rdd .RDD
4343import org .apache .spark .rpc .RpcEnv
4444import org .apache .spark .scheduler .{FakeTask , ResultTask , TaskDescription }
45- import org .apache .spark .serializer .JavaSerializer
45+ import org .apache .spark .serializer .{ JavaSerializer , SerializerManager }
4646import org .apache .spark .shuffle .FetchFailedException
4747import org .apache .spark .storage .BlockManagerId
4848import org .apache .spark .util .UninterruptibleThread
@@ -234,6 +234,7 @@ class ExecutorSuite extends SparkFunSuite with LocalSparkContext with MockitoSug
234234 val mockMemoryManager = mock[MemoryManager ]
235235 when(mockEnv.conf).thenReturn(conf)
236236 when(mockEnv.serializer).thenReturn(serializer)
237+ when(mockEnv.serializerManager).thenReturn(mock[SerializerManager ])
237238 when(mockEnv.rpcEnv).thenReturn(mockRpcEnv)
238239 when(mockEnv.metricsSystem).thenReturn(mockMetricsSystem)
239240 when(mockEnv.memoryManager).thenReturn(mockMemoryManager)
You can’t perform that action at this time.
0 commit comments