From b7a2c866783b0d225fb4b99ade5f46995c86d560 Mon Sep 17 00:00:00 2001 From: EmergentOrder Date: Sat, 26 Mar 2016 10:10:57 -0600 Subject: [PATCH] remove debug prints --- .../scala/io/prediction/core/SelfCleaningDataSource.scala | 4 ---- 1 file changed, 4 deletions(-) diff --git a/core/src/main/scala/io/prediction/core/SelfCleaningDataSource.scala b/core/src/main/scala/io/prediction/core/SelfCleaningDataSource.scala index b326bb925b..1007bec225 100644 --- a/core/src/main/scala/io/prediction/core/SelfCleaningDataSource.scala +++ b/core/src/main/scala/io/prediction/core/SelfCleaningDataSource.scala @@ -165,11 +165,7 @@ trait SelfCleaningDataSource { ): Unit = { val (appId, channelId) = Common.appNameToId(appName, None) - newEvents.foreach(println(_)) - pEventsDb.write(newEvents, appId)(sc) - - eventsToRemove.foreach(println(_)) removeEvents(eventsToRemove.collect.toSet, appId) }