bulker replacetable_stream: properly set final table name

jitsucom · Mar 7, 2024 · 1e59115 · 1e59115
1 parent 6812514
commit 1e59115
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/bulkerlib/implementations/sql/replacetable_stream.go b/bulkerlib/implementations/sql/replacetable_stream.go
@@ -59,6 +59,7 @@ func (ps *ReplaceTableStream) Complete(ctx context.Context) (state bulker.State,
 			if ok {
 				r.Name = ps.tableName
 				r.Temporary = false
+				ps.state.Representation = r
 			}
 			err1 := ps.tx.ReplaceTable(ctx, ps.tableName, ps.tmpTable, true)
 			if errorx.IsOfType(err1, errorj.DropError) {