fix

jitsucom · Sep 19, 2024 · 7ef29c2 · 7ef29c2
1 parent 9792fe6
commit 7ef29c2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/bulkerlib/implementations/sql/abstract_transactional.go b/bulkerlib/implementations/sql/abstract_transactional.go
@@ -161,7 +161,7 @@ func (ps *AbstractTransactionalSQLStream) flushBatchFile(ctx context.Context) (s
 		ps.eventsInBatch = 0
 	}()
 	if ps.batchFile != nil && ps.eventsInBatch > 0 {
-		_, err = ps.sqlAdapter.TableHelper().EnsureTableWithCaching(ctx, ps.tx, ps.id, table)
+		_, err = ps.sqlAdapter.TableHelper().EnsureTableWithoutCaching(ctx, ps.tx, ps.id, table)
 		if err != nil {
 			return state, errorj.Decorate(err, "failed to create table")
 		}