[incubator-doris] 03/10: [Bug] Fix null pointer when replay RollupJob (#4572)

[morningman]

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

morningman pushed a commit to branch branch-0.13
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git

commit 3b4564b52e0d5929404d1ba8e8c0ce391bb6428c
Author: EmmyMiao87 <522274...@qq.com>
AuthorDate: Thu Sep 10 11:55:14 2020 +0800

    [Bug] Fix null pointer when replay RollupJob (#4572)
    
    When fe replay rollup job(v1) with deleted table, it will throw null 
pointer exception and exit.
    This commit ignore this error and print a warning log to avoid fe exit.
    
    Fixed #4571
    
    Change-Id: I302b554a94d42aee645db6b224cd989e00cd3ca6
---
 fe/fe-core/src/main/java/org/apache/doris/alter/RollupJob.java | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/alter/RollupJob.java 
b/fe/fe-core/src/main/java/org/apache/doris/alter/RollupJob.java
index 5cd474b..15d07f7 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/alter/RollupJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/alter/RollupJob.java
@@ -903,6 +903,10 @@ public class RollupJob extends AlterJob {
         db.writeLock();
         try {
             OlapTable olapTable = (OlapTable) db.getTable(tableId);
+            if (olapTable == null) {
+                LOG.warn("table {} could not be found when replay rollup job", 
tableId);
+                return;
+            }
             olapTable.setState(OlapTableState.NORMAL);
         } finally {
             db.writeUnlock();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org