Skip to content

Commit 0e26c3d

Browse files
committed
revert PythonScan description change
1 parent 1cedfec commit 0e26c3d

File tree

1 file changed

+1
-10
lines changed
  • sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python

1 file changed

+1
-10
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/python/PythonScan.scala

Lines changed: 1 addition & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -43,16 +43,7 @@ class PythonScan(
4343
override def toMicroBatchStream(checkpointLocation: String): MicroBatchStream =
4444
new PythonMicroBatchStream(ds, shortName, outputSchema, options)
4545

46-
override def description: String = {
47-
val metadataStr = getMetaData().toSeq.sorted.map {
48-
case (key, value) =>
49-
val redactedValue =
50-
Utils.redact(sparkSession.sessionState.conf.stringRedactionPattern, value)
51-
key + ": " + StringUtils.abbreviate(
52-
redactedValue, sparkSession.sessionState.conf.maxMetadataStringLength)
53-
}.mkString(", ")
54-
s"(Python) $metadataStr"
55-
}
46+
override def description: String = "(Python)"
5647

5748
override def readSchema(): StructType = outputSchema
5849

0 commit comments

Comments
 (0)