only setDBClientSettings if filter != nil

Signed-off-by: Shlomi Noach <[email protected]>
vitessio · Jan 1, 2025 · 79d07b3 · 79d07b3
1 parent b3e9fdc
commit 79d07b3
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/go/vt/vttablet/tabletmanager/vreplication/vplayer_parallel_pool.go b/go/vt/vttablet/tabletmanager/vreplication/vplayer_parallel_pool.go
@@ -68,8 +68,10 @@ func newParallelWorkersPool(size int, dbClientGen dbClientGenerator, vp *vplayer
 		if err != nil {
 			return nil, err
 		}
-		if err := setDBClientSettings(dbClient, vp.vr.workflowConfig); err != nil {
-			return nil, err
+		if vp.vr.source.Filter != nil {
+			if err := setDBClientSettings(dbClient, vp.vr.workflowConfig); err != nil {
+				return nil, err
+			}
 		}
 
 		w.dbClient = newVDBClient(dbClient, vp.vr.stats, 0)