Fix binlog replication

apecloud · Sep 12, 2024 · 220605f · 220605f
1 parent e4ea17f
commit 220605f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/replication.go b/replication.go
@@ -37,7 +37,7 @@ func registerReplicaController(provider *catalog.DatabaseProvider, engine *sqle.
 	replica := binlogreplication.MyBinlogReplicaController
 	replica.SetEngine(engine)
 
-	session := memory.NewSession(sql.NewBaseSession(), provider)
+	session := backend.NewSession(memory.NewSession(sql.NewBaseSession(), provider), provider, pool)
 	ctx := sql.NewContext(context.Background(), sql.WithSession(session))
 	ctx.SetCurrentDatabase("mysql")
 	replica.SetExecutionContext(ctx)