Skip to content

Commit 61f9089

Browse files
committed
small fix
1 parent 9bc07e3 commit 61f9089

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSinkLog.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ class FileStreamSinkLog(
100100

101101
val retentionMs: Long = _retentionMs match {
102102
case Some(retention) =>
103-
logInfo(s"Retention is set to ${_retentionMs.get} ms")
103+
logInfo(s"Retention is set to $retention ms")
104104
retention
105105

106106
case _ => Long.MaxValue

0 commit comments

Comments
 (0)