diff --git a/pkg/tm/transaction_executor.go b/pkg/tm/transaction_executor.go index 1a57c4fd3..4acf74c88 100644 --- a/pkg/tm/transaction_executor.go +++ b/pkg/tm/transaction_executor.go @@ -65,7 +65,7 @@ func Begin(ctx context.Context, name string) context.Context { } // todo timeout should read from config - err := GetGlobalTransactionManager().Begin(ctx, tx, 60000*30, name) + err := GetGlobalTransactionManager().Begin(ctx, tx, time.Second*30, name) if err != nil { panic(fmt.Sprintf("transactionTemplate: begin transaction failed, error %v", err)) }