(fix) Remove duplicated transform application (#5283)

spotify · Feb 29, 2024 · a658edb · a658edb
1 parent a252482
commit a658edb
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/scio-smb/src/main/scala/com/spotify/scio/smb/SortMergeTransform.scala b/scio-smb/src/main/scala/com/spotify/scio/smb/SortMergeTransform.scala
@@ -196,9 +196,8 @@ object SortMergeTransform {
         }
       }
       val t = transform.via(fn, sideViews)
-      sc.applyInternal(t)
-
       val writeResult = sc.applyInternal(t)
+
       ClosedTap(SmbIO.tap(t.getFileOperations, writeResult).apply(sc))
     }
   }