Style fixes

tdas · tdas · commit 7adca7004085 · 2016-03-14T02:15:31.000-07:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala
@@ -50,7 +50,6 @@ private[state] object StateStore extends Logging {
       startIfNeeded()
       loadedStores.getOrElseUpdate(storeId, new StateStore(storeId, directory))
     }
-    println(s"Got state store $storeId")
     reportActiveInstance(storeId)
     store
   }
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStoreRDD.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStoreRDD.scala
@@ -47,7 +47,6 @@ class StateStoreRDD[INPUT: ClassTag, OUTPUT: ClassTag](
     var store: StateStore = null
 
     Utils.tryWithSafeFinally {
-      println(s"Getting store for version $newStoreVersion")
       store = StateStore.get(
         StateStoreId(operatorId, partition.index),
         storeDirectory

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,6 @@ private[state] object StateStore extends Logging {`
`50`	`50`	`startIfNeeded()`
`51`	`51`	`loadedStores.getOrElseUpdate(storeId, new StateStore(storeId, directory))`
`52`	`52`	`}`
`53`		`- println(s"Got state store $storeId")`
`54`	`53`	`reportActiveInstance(storeId)`
`55`	`54`	`store`
`56`	`55`	`}`