manually set false about SLING_PROCESS_BW

fix slingdata-io#11 ref: flarco/g#1
yokofly · Oct 14, 2024 · c10feda · c10feda
1 parent 4d365e7
commit c10feda
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/core/sling/task_run_write.go b/core/sling/task_run_write.go
@@ -133,6 +133,11 @@ func (t *TaskExecution) WriteToFile(cfg *Config, df *iop.Dataflow) (cnt uint64,
 func (t *TaskExecution) WriteToDb(cfg *Config, df *iop.Dataflow, tgtConn database.Connection) (cnt uint64, err error) {
 	defer t.PBar.Finish()
 
+	// Force SLING_PROCESS_BW to false for Proton
+	if tgtConn.GetType() == dbio.TypeDbProton {
+		os.Setenv("SLING_PROCESS_BW", "false")
+	}
+
 	// detect empty
 	if len(df.Columns) == 0 {
 		err = g.Error("no stream columns detected")