test

aerospike-community · Nov 17, 2016 · 2240130 · 2240130
1 parent dc05f3f
commit 2240130
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/...s/spark_session_rollup/src/main/java/com/aerospike/spark/examples/SparkSessionRollup.java b/...s/spark_session_rollup/src/main/java/com/aerospike/spark/examples/SparkSessionRollup.java
@@ -235,7 +235,7 @@ public static void main(String[] args) {
         JavaSparkContext sc = new JavaSparkContext(conf);
         sc.addJar("build/libs/spark_session_rollup.jar");
 
-        JavaRDD<String> entries = sc.textFile("hdfs://localhost:54310/tmp");
+        JavaRDD<String> entries = sc.textFile("hdfs://localhost:54310/tmp/input");
 
         JavaPairRDD<Long, Iterable<Long>> userhits =
             entries.mapToPair(new ExtractHits()).groupByKey();

diff --git a/settings.gradle b/settings.gradle
@@ -1,3 +1,4 @@
+
 include ':mapreduce'
 include ':sampledata'
 include ':examples:word_count_input'