Removed extra code

apache · Mar 9, 2019 · 27ab9f0 · 27ab9f0
1 parent fc7487b
commit 27ab9f0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/CacheManager.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/CacheManager.scala
@@ -191,7 +191,7 @@ class CacheManager extends Logging {
     val cachedDataCopy = readLock {
       cachedData.asScala.clone()
     }
-    val needToRecache = cachedDataCopy.filter(cd => condition(cd))
+    val needToRecache = cachedDataCopy.filter(condition)
     needToRecache.map { cd =>
       writeLock {
         // Remove the cache entry before we create a new one, so that we can have a different