This is an automated email from the ASF dual-hosted git repository.

jshao pushed a commit to branch branch-0.9
in repository https://gitbox.apache.org/repos/asf/gravitino.git


The following commit(s) were added to refs/heads/branch-0.9 by this push:
     new 891a44d28e [#7403] fix(core): Fix bugs in SQL session commit in the 
core module (#7407)
891a44d28e is described below

commit 891a44d28ecb63362f8e539baae799491a94b8c5
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Jun 16 09:58:21 2025 -0700

    [#7403] fix(core): Fix bugs in SQL session commit in the core module (#7407)
    
    ### What changes were proposed in this pull request?
    
    Replace `doWithCommitAndFetchResult` with
    `doWithoutCommitAndFetchResult` in the method `deleteColumnsByTableId`.
    
    ### Why are the changes needed?
    
    The method is used in `doMultipleWithCommit` and should not use
    `doWithCommitAndFetchResult`.
    
    Fix: #7403
    
    ### Does this PR introduce _any_ user-facing change?
    
    N/A.
    
    ### How was this patch tested?
    
    Existing UTs and ITs.
    
    Co-authored-by: Mini Yu <[email protected]>
---
 .../gravitino/storage/relational/service/TableColumnMetaService.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/core/src/main/java/org/apache/gravitino/storage/relational/service/TableColumnMetaService.java
 
b/core/src/main/java/org/apache/gravitino/storage/relational/service/TableColumnMetaService.java
index 9e2b3530d0..1527811fa9 100644
--- 
a/core/src/main/java/org/apache/gravitino/storage/relational/service/TableColumnMetaService.java
+++ 
b/core/src/main/java/org/apache/gravitino/storage/relational/service/TableColumnMetaService.java
@@ -100,7 +100,7 @@ public class TableColumnMetaService {
   boolean deleteColumnsByTableId(Long tableId) {
     // deleteColumns will be done in deleteTable transaction, so we don't do 
commit here.
     Integer result =
-        SessionUtils.doWithCommitAndFetchResult(
+        SessionUtils.doWithoutCommitAndFetchResult(
             TableColumnMapper.class, mapper -> 
mapper.softDeleteColumnsByTableId(tableId));
     return result > 0;
   }

Reply via email to