Removes obsolete comment.

For temp files/folders call the deleteOnExit
lensesio · Apr 30, 2024 · ac30b97 · ac30b97
1 parent e0dcb60
commit ac30b97
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/...ct-aws-s3/src/it/scala/io/lenses/streamreactor/connect/aws/s3/source/TempFileHelper.scala b/...ct-aws-s3/src/it/scala/io/lenses/streamreactor/connect/aws/s3/source/TempFileHelper.scala
@@ -10,7 +10,9 @@ trait TempFileHelper {
     val folder     = new File(folderName)
     try {
       folder.mkdir()
+      folder.deleteOnExit()
       val file = new File(folder, fileName)
+      file.deleteOnExit()
       f(file)
     } catch {
       case e: Throwable => Left(e)

diff --git a/.../src/main/scala/io/lenses/streamreactor/connect/cloud/common/sink/writer/WriteState.scala b/.../src/main/scala/io/lenses/streamreactor/connect/cloud/common/sink/writer/WriteState.scala
@@ -50,7 +50,6 @@ case class Writing(
 ) extends WriteState(commitState)
     with LazyLogging {
 
-  //TODO: it's not clear why we are only keeping track of one schema (VALUE) and not key/and headers
   def update(o: Offset, recordTimestamp: Long, schema: Option[Schema]): WriteState = {
     logger.debug(
       s"state update: Uncommitted offset update $uncommittedOffset => $o, earliest record timestamp $earliestRecordTimestamp => $recordTimestamp",