This is an automated email from the ASF dual-hosted git repository.
zeroshade pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg-go.git
The following commit(s) were added to refs/heads/main by this push:
new 48d094d fix(catalog/sql): change isolation to LevelDefault (#279)
48d094d is described below
commit 48d094d1b821fbfc7dd99aac9c503b8b25a01390
Author: Matt Topol <[email protected]>
AuthorDate: Wed Jan 29 18:04:39 2025 -0500
fix(catalog/sql): change isolation to LevelDefault (#279)
---
catalog/sql/sql.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/catalog/sql/sql.go b/catalog/sql/sql.go
index 9972582..010744c 100644
--- a/catalog/sql/sql.go
+++ b/catalog/sql/sql.go
@@ -156,7 +156,7 @@ func withReadTx[R any](ctx context.Context, db *bun.DB, fn
func(context.Context,
}
func withWriteTx(ctx context.Context, db *bun.DB, fn func(context.Context,
bun.Tx) error) error {
- return db.RunInTx(ctx, &sql.TxOptions{Isolation:
sql.LevelLinearizable}, func(ctx context.Context, tx bun.Tx) error {
+ return db.RunInTx(ctx, &sql.TxOptions{Isolation: sql.LevelDefault},
func(ctx context.Context, tx bun.Tx) error {
return fn(ctx, tx)
})
}