diff --git a/external/flume/src/main/scala/org/apache/spark/streaming/flume/EventTransformer.scala b/external/flume/src/main/scala/org/apache/spark/streaming/flume/EventTransformer.scala
index 069a9a215675c..dc629df4f4ac2 100644
--- a/external/flume/src/main/scala/org/apache/spark/streaming/flume/EventTransformer.scala
+++ b/external/flume/src/main/scala/org/apache/spark/streaming/flume/EventTransformer.scala
@@ -28,7 +28,7 @@ import org.apache.spark.Logging
  * A simple object that provides the implementation of readExternal and writeExternal for both
  * the wrapper classes for Flume-style Events.
  */
-object EventTransformer extends Logging {
+private[streaming] object EventTransformer extends Logging {
   def readExternal(in: ObjectInput): (java.util.HashMap[CharSequence, CharSequence],
     Array[Byte]) = {
     val bodyLength = in.readInt()
diff --git a/external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumePollingInputDStream.scala b/external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumePollingInputDStream.scala
index 6d7a74f7a9020..01de8781615a7 100644
--- a/external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumePollingInputDStream.scala
+++ b/external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumePollingInputDStream.scala
@@ -37,10 +37,9 @@ import org.apache.spark.streaming.dstream.ReceiverInputDStream
 import org.apache.spark.streaming.receiver.Receiver
 import org.apache.spark.streaming.flume.sink._
 
-
 /**
  * A [[ReceiverInputDStream]] that can be used to read data from several Flume agents running
- * [[org.apache.spark.flume.sink.SparkSink]]s.
+ * [[org.apache.spark.streaming.flume.sink.SparkSink]]s.
  * @param _ssc Streaming context that will execute this input stream
  * @param addresses List of addresses at which SparkSinks are listening
  * @param maxBatchSize Maximum size of a batch
@@ -48,8 +47,7 @@ import org.apache.spark.streaming.flume.sink._
  * @param storageLevel The storage level to use.
  * @tparam T Class type of the object of this stream
  */
-private[streaming]
-class FlumePollingInputDStream[T: ClassTag](
+private[streaming] class FlumePollingInputDStream[T: ClassTag](
     @transient _ssc: StreamingContext,
     val addresses: Seq[InetSocketAddress],
     val maxBatchSize: Int,
@@ -62,8 +60,7 @@ class FlumePollingInputDStream[T: ClassTag](
   }
 }
 
-private[streaming]
-class FlumePollingReceiver(
+private[streaming] class FlumePollingReceiver(
     addresses: Seq[InetSocketAddress],
     maxBatchSize: Int,
     parallelism: Int,
diff --git a/external/flume/src/test/java/org/apache/spark/streaming/flume/JavaFlumePollingStreamSuite.java b/external/flume/src/test/java/org/apache/spark/streaming/flume/JavaFlumePollingStreamSuite.java
index ef8622481d599..a30157b94b972 100644
--- a/external/flume/src/test/java/org/apache/spark/streaming/flume/JavaFlumePollingStreamSuite.java
+++ b/external/flume/src/test/java/org/apache/spark/streaming/flume/JavaFlumePollingStreamSuite.java
@@ -1,3 +1,20 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package org.apache.spark.streaming.flume;
 
 import java.net.InetSocketAddress;