Move CommitDeniedException to executors package; remove @DeveloperAPI annotation.

Author: JoshRosen

core/src/main/scala/org/apache/spark/SparkEnv.scala

@@ -20,8 +20,6 @@ package org.apache.spark
 import java.io.File
 import java.net.Socket
 
-import org.apache.spark.scheduler.OutputCommitCoordinator.OutputCommitCoordinatorActor
-
 import scala.collection.JavaConversions._
 import scala.collection.mutable
 import scala.util.Properties
@@ -37,6 +35,7 @@ import org.apache.spark.network.BlockTransferService
 import org.apache.spark.network.netty.NettyBlockTransferService
 import org.apache.spark.network.nio.NioBlockTransferService
 import org.apache.spark.scheduler.{OutputCommitCoordinator, LiveListenerBus}
+import org.apache.spark.scheduler.OutputCommitCoordinator.OutputCommitCoordinatorActor
 import org.apache.spark.serializer.Serializer
 import org.apache.spark.shuffle.{ShuffleMemoryManager, ShuffleManager}
 import org.apache.spark.storage._

core/src/main/scala/org/apache/spark/SparkHadoopWriter.scala

@@ -26,9 +26,9 @@ import org.apache.hadoop.mapred._
 import org.apache.hadoop.fs.FileSystem
 import org.apache.hadoop.fs.Path
 
+import org.apache.spark.executor.CommitDeniedException
 import org.apache.spark.mapred.SparkHadoopMapRedUtil
 import org.apache.spark.rdd.HadoopRDD
-import org.apache.spark.util.AkkaUtils
 
 /**
  * Internal helper class that saves an RDD using a Hadoop OutputFormat.

…apache/spark/CommitDeniedException.scala …ark/executor/CommitDeniedException.scalacore/src/main/scala/org/apache/spark/CommitDeniedException.scala renamed to core/src/main/scala/org/apache/spark/executor/CommitDeniedException.scala core/src/main/scala/org/apache/spark/CommitDeniedException.scala renamed to core/src/main/scala/org/apache/spark/executor/CommitDeniedException.scala

@@ -15,18 +15,22 @@
  * limitations under the License.
  */
 
-package org.apache.spark
+package org.apache.spark.executor
 
-import org.apache.spark.annotation.DeveloperApi
+import org.apache.spark.{TaskCommitDenied, TaskEndReason}
 
 /**
- * :: DeveloperApi ::
  * Exception thrown when a task attempts to commit output to Hadoop, but
  * is denied by the driver.
  */
-@DeveloperApi
-class CommitDeniedException(msg: String, jobID: Int, splitID: Int, attemptID: Int)
+class CommitDeniedException(
+    msg: String,
+    jobID: Int,
+    splitID: Int,
+    attemptID: Int)
   extends Exception(msg) {
-  def toTaskEndReason(): TaskEndReason = new TaskCommitDenied(jobID, splitID, attemptID)
+
+  def toTaskEndReason: TaskEndReason = new TaskCommitDenied(jobID, splitID, attemptID)
+
 }