remove the debug info

Signed-off-by: openinx <[email protected]>

Author: openinx

spark/src/main/scala/org/apache/spark/sql/delta/Checkpoints.scala

@@ -18,7 +18,7 @@ package org.apache.spark.sql.delta
 
 import java.io.FileNotFoundException
 import java.util.UUID
-import scala.collection.convert.ImplicitConversions.`map AsScala`
+
 import scala.collection.mutable
 import scala.math.Ordering.Implicits._
 import scala.util.Try
@@ -549,12 +549,6 @@ trait Checkpoints extends DeltaLogging {
   /** Returns the last complete checkpoint in the delta log directory (if any) */
   private def findLastCompleteCheckpoint(): Option[CheckpointInstance] = {
     val hadoopConf = newDeltaHadoopConf()
-
-    // scalastyle:off println
-    hadoopConf.getPropsWithPrefix("fs.s3a.").toSeq.sortBy(_._1)
-      .foreach{ case (k, v) => println(s"findLastCompleteCheckpoint -> fs.s3a.$k = $v")}
-    // scalastyle:on println
-
     val listingResult = store
       .listFrom(listingPrefix(logPath, 0L), hadoopConf)
       // Checkpoint files of 0 size are invalid but Spark will ignore them silently when

spark/src/main/scala/org/apache/spark/sql/delta/sources/DeltaSink.scala

@@ -60,11 +60,6 @@ case class DeltaSink(
     with UpdateExpressionsSupport
     with DeltaLogging {
 
-  // scalastyle:off println
-  options.options.foreach{ case (k, v) => println(s"DeltaSink#options --> key: $k --> val: $v")}
-  println(s"CatalogTable is Present ? --> ${catalogTable.isDefined}")
-  // scalastyle:on println
-
   private lazy val deltaLog = DeltaUtils.getDeltaLogFromTableOrPath(
     sqlContext.sparkSession, catalogTable, path)
 

spark/src/main/scala/org/apache/spark/sql/delta/util/Utils.scala

@@ -66,14 +66,6 @@ object Utils {
       catalogTableOpt: Option[CatalogTable],
       path: Path,
       options: Map[String, String] = Map.empty): DeltaLog = {
-
-    // scalastyle:off
-    println(s"getDeltaLogFromTableOrPath --> catalogTableOpt is present ? ${catalogTableOpt.isDefined}")
-    catalogTableOpt.foreach{
-      c => c.storage.properties.foreach{case (k, v) =>
-        println(s"getDeltaLogFromTableOrPath--> catalogTableOps: key: $k --> val: $v")}}
-    // scalastyle:on
-
     catalogTableOpt
       .map(catalogTable => DeltaLog.forTable(sparkSession, catalogTable, options))
       .getOrElse(DeltaLog.forTable(sparkSession, path, options))