Tidying up

apache · Apr 5, 2022 · 7999d8f · 7999d8f
1 parent d5f6506
commit 7999d8f
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/...datasource/hudi-spark-common/src/main/scala/org/apache/hudi/ColumnStatsIndexSupport.scala b/...datasource/hudi-spark-common/src/main/scala/org/apache/hudi/ColumnStatsIndexSupport.scala
@@ -178,12 +178,10 @@ trait ColumnStatsIndexSupport extends SparkAdapterSupport {
   }
 
   private def readFullColumnStatsIndexInternal(spark: SparkSession, tableBasePath: String) = {
-    // Read Metadata Table's Column Stats Index into Spark's [[DataFrame]]
     val metadataTablePath = HoodieTableMetadata.getMetadataTableBasePath(tableBasePath)
-    val metadataTableDF = spark.read.format("org.apache.hudi")
+    // Read Metadata Table's Column Stats Index into Spark's [[DataFrame]]
+    spark.read.format("org.apache.hudi")
       .load(s"$metadataTablePath/${MetadataPartitionType.COLUMN_STATS.getPartitionPath}")
-
-    metadataTableDF
   }
 
   private def readColumnStatsIndexForColumnsInternal(spark: SparkSession, targetColumns: Seq[String], metadataConfig: HoodieMetadataConfig, tableBasePath: String) = {