@@ -77,9 +77,9 @@ class FileStreamSinkLogSuite extends SparkFunSuite with SharedSparkSession {
7777
7878 // scalastyle:off
7979 val expected = s """ v $VERSION
80- |{"path":"/a/b/x","size":100,"isDir":false,"modificationTime":1000,"blockReplication":1,"blockSize":10000,"action":"add","commitTime":1000 }
81- |{"path":"/a/b/y","size":200,"isDir":false,"modificationTime":2000,"blockReplication":2,"blockSize":20000,"action":"delete","commitTime":2000 }
82- |{"path":"/a/b/z","size":300,"isDir":false,"modificationTime":3000,"blockReplication":3,"blockSize":30000,"action":"add","commitTime":3000 } """ .stripMargin
80+ |{"path":"/a/b/x","size":100,"isDir":false,"modificationTime":1000,"blockReplication":1,"blockSize":10000,"action":"add"}
81+ |{"path":"/a/b/y","size":200,"isDir":false,"modificationTime":2000,"blockReplication":2,"blockSize":20000,"action":"delete"}
82+ |{"path":"/a/b/z","size":300,"isDir":false,"modificationTime":3000,"blockReplication":3,"blockSize":30000,"action":"add"} """ .stripMargin
8383 // scalastyle:on
8484 val baos = new ByteArrayOutputStream ()
8585 sinkLog.serialize(logs, baos)
@@ -94,9 +94,9 @@ class FileStreamSinkLogSuite extends SparkFunSuite with SharedSparkSession {
9494 withFileStreamSinkLog { sinkLog =>
9595 // scalastyle:off
9696 val logs = s """ v $VERSION
97- |{"path":"/a/b/x","size":100,"isDir":false,"modificationTime":1000,"blockReplication":1,"blockSize":10000,"action":"add","commitTime":1000 }
98- |{"path":"/a/b/y","size":200,"isDir":false,"modificationTime":2000,"blockReplication":2,"blockSize":20000,"action":"delete","commitTime":2000 }
99- |{"path":"/a/b/z","size":300,"isDir":false,"modificationTime":3000,"blockReplication":3,"blockSize":30000,"action":"add","commitTime":3000 } """ .stripMargin
97+ |{"path":"/a/b/x","size":100,"isDir":false,"modificationTime":1000,"blockReplication":1,"blockSize":10000,"action":"add"}
98+ |{"path":"/a/b/y","size":200,"isDir":false,"modificationTime":2000,"blockReplication":2,"blockSize":20000,"action":"delete"}
99+ |{"path":"/a/b/z","size":300,"isDir":false,"modificationTime":3000,"blockReplication":3,"blockSize":30000,"action":"add"} """ .stripMargin
100100 // scalastyle:on
101101
102102 val expected = Seq (
0 commit comments