Fix warn filter

databricks · Jan 27, 2016 · 1a3e765 · 1a3e765
1 parent 13dca89
commit 1a3e765
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/com/oreilly/learningsparkexamples/scala/BasicFilterUnionCombo.scala b/src/main/scala/com/oreilly/learningsparkexamples/scala/BasicFilterUnionCombo.scala
@@ -13,7 +13,7 @@ object BasicFilterUnionCombo {
       val sc = new SparkContext(conf)
       val inputRDD = sc.textFile(args(1))
       val errorsRDD = inputRDD.filter(_.contains("error"))
-      val warningsRDD = inputRDD.filter(_.contains("error"))
+      val warningsRDD = inputRDD.filter(_.contains("warn"))
       val badLinesRDD = errorsRDD.union(warningsRDD)
       println(badLinesRDD.collect().mkString("\n"))
     }