fix WriteDataflow to use fs props

slingdata-io · Oct 24, 2024 · 6d63a1d · 6d63a1d
1 parent 90f3f7f
commit 6d63a1d
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/core/dbio/filesys/fs.go b/core/dbio/filesys/fs.go
@@ -620,7 +620,10 @@ func WriteDataflow(fs FileSysClient, df *iop.Dataflow, url string) (bw int64, er
 		}
 	}()
 
-	return fs.Self().WriteDataflowReady(df, url, fileReadyChn, df.StreamConfig())
+	sp := iop.NewStreamProcessor()
+	sp.SetConfig(fs.Client().Props())
+
+	return fs.Self().WriteDataflowReady(df, url, fileReadyChn, sp.Config)
 }
 
 // GetReaders returns one or more readers from specified paths in specified FileSysClient