Skip to content
Snippets Groups Projects
Commit adb2ff75 authored by Jongyoul Lee's avatar Jongyoul Lee Committed by Sean Owen
Browse files

[SPARK-6453][Mesos] Some Mesos*Suite have a different package with their classes

- Moved Suites from o.a.s.s.mesos to o.a.s.s.cluster.mesos

Author: Jongyoul Lee <jongyoul@gmail.com>

Closes #5126 from jongyoul/SPARK-6453 and squashes the following commits:

4f24a3e [Jongyoul Lee] [SPARK-6453][Mesos] Some Mesos*Suite have a different package with their classes - Fixed imports orders
8ab149d [Jongyoul Lee] [SPARK-6453][Mesos] Some Mesos*Suite have a different package with their classes - Moved Suites from o.a.s.s.mesos to o.a.s.s.cluster.mesos
parent ab4f516f
No related branches found
No related tags found
No related merge requests found
...@@ -15,7 +15,7 @@ ...@@ -15,7 +15,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.apache.spark.scheduler.mesos package org.apache.spark.scheduler.cluster.mesos
import java.nio.ByteBuffer import java.nio.ByteBuffer
import java.util import java.util
...@@ -24,21 +24,20 @@ import java.util.Collections ...@@ -24,21 +24,20 @@ import java.util.Collections
import scala.collection.mutable import scala.collection.mutable
import scala.collection.mutable.ArrayBuffer import scala.collection.mutable.ArrayBuffer
import org.apache.mesos.SchedulerDriver
import org.apache.mesos.Protos._
import org.apache.mesos.Protos.Value.Scalar import org.apache.mesos.Protos.Value.Scalar
import org.mockito.Mockito._ import org.apache.mesos.Protos._
import org.apache.mesos.SchedulerDriver
import org.mockito.Matchers._ import org.mockito.Matchers._
import org.mockito.Mockito._
import org.mockito.{ArgumentCaptor, Matchers} import org.mockito.{ArgumentCaptor, Matchers}
import org.scalatest.FunSuite import org.scalatest.FunSuite
import org.scalatest.mock.MockitoSugar import org.scalatest.mock.MockitoSugar
import org.apache.spark.{LocalSparkContext, SparkConf, SparkContext}
import org.apache.spark.executor.MesosExecutorBackend import org.apache.spark.executor.MesosExecutorBackend
import org.apache.spark.scheduler.cluster.ExecutorInfo
import org.apache.spark.scheduler.{LiveListenerBus, SparkListenerExecutorAdded, import org.apache.spark.scheduler.{LiveListenerBus, SparkListenerExecutorAdded,
TaskDescription, TaskSchedulerImpl, WorkerOffer} TaskDescription, TaskSchedulerImpl, WorkerOffer}
import org.apache.spark.scheduler.cluster.ExecutorInfo import org.apache.spark.{LocalSparkContext, SparkConf, SparkContext}
import org.apache.spark.scheduler.cluster.mesos.{MesosSchedulerBackend, MemoryUtils}
class MesosSchedulerBackendSuite extends FunSuite with LocalSparkContext with MockitoSugar { class MesosSchedulerBackendSuite extends FunSuite with LocalSparkContext with MockitoSugar {
......
...@@ -15,14 +15,12 @@ ...@@ -15,14 +15,12 @@
* limitations under the License. * limitations under the License.
*/ */
package org.apache.spark.scheduler.mesos package org.apache.spark.scheduler.cluster.mesos
import java.nio.ByteBuffer import java.nio.ByteBuffer
import org.scalatest.FunSuite import org.scalatest.FunSuite
import org.apache.spark.scheduler.cluster.mesos.MesosTaskLaunchData
class MesosTaskLaunchDataSuite extends FunSuite { class MesosTaskLaunchDataSuite extends FunSuite {
test("serialize and deserialize data must be same") { test("serialize and deserialize data must be same") {
val serializedTask = ByteBuffer.allocate(40) val serializedTask = ByteBuffer.allocate(40)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment