fixed explanaiton

markhamstra · Aug 21, 2014 · 93f7637 · 93f7637
1 parent 50fd6f9
commit 93f7637
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/streaming/pom.xml b/streaming/pom.xml
@@ -79,7 +79,7 @@
       </plugin>
 
       <!--
-           This plugin forces the generation of jar containing streaming test classes, 
+           This plugin forces the generation of jar containing streaming test classes,
            so that the tests classes of external modules can use them. The two execution profiles
            are necessary - first one for 'mvn package', second one for 'mvn test-compile'. Ideally,
            'mvn compile' should not compile test classes and therefore should not need this. 

diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonRDDFunction.java
@@ -5,7 +5,7 @@
 
 /*
  * Interface for py4j callback function.
- * This function is called by pyspark.streaming.dstream.DStream.foreachRDD .
+ * This interface is related to pyspark.streaming.dstream.DStream.foreachRDD .
  */
 public interface PythonRDDFunction {
   JavaRDD<byte[]> call(JavaRDD<byte[]> rdd, long time);