You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@impala.apache.org by cs...@apache.org on 2023/03/22 10:40:36 UTC

[impala] branch master updated: IMPALA-12002: COMMIT_COMPACTION_EVENT should silently fail if the db is not found

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

csringhofer pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/impala.git


The following commit(s) were added to refs/heads/master by this push:
     new 5607fba4f IMPALA-12002: COMMIT_COMPACTION_EVENT should silently fail if the db is not found
5607fba4f is described below

commit 5607fba4ff8b2a7bd789cb5dd873ff0ff3f3ad3c
Author: Sai Hemanth Gantasala <sa...@cloudera.com>
AuthorDate: Wed Mar 15 20:58:40 2023 -0700

    IMPALA-12002: COMMIT_COMPACTION_EVENT should silently fail if the db
    is not found
    
    In the test runs, it is found that event processor is stopped when
    processing a commit compaction event due to database being droppped.
    Instead of stopping the event processor, it is enough to throw a warn
    message and skip the commit compaction event.
    
    Change-Id: I543abc596efa710f903b2e20d6a8ed73a8d5a315
    Reviewed-on: http://gerrit.cloudera.org:8080/19625
    Reviewed-by: Impala Public Jenkins <im...@cloudera.com>
    Tested-by: Impala Public Jenkins <im...@cloudera.com>
---
 fe/src/main/java/org/apache/impala/catalog/events/MetastoreEvents.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/fe/src/main/java/org/apache/impala/catalog/events/MetastoreEvents.java b/fe/src/main/java/org/apache/impala/catalog/events/MetastoreEvents.java
index 805f58093..fabdfc37d 100644
--- a/fe/src/main/java/org/apache/impala/catalog/events/MetastoreEvents.java
+++ b/fe/src/main/java/org/apache/impala/catalog/events/MetastoreEvents.java
@@ -2681,8 +2681,7 @@ public class MetastoreEvents {
           msTbl_ = tbl.getMetaStoreTable();
         }
       } catch (Exception ex) {
-        throw new MetastoreNotificationException(debugString("Unable to "
-            + "parse commit compaction message"), ex);
+        warnLog("Unable to parse commit compaction message: {}", ex.getMessage());
       }
     }