From ded6502d80b2d85b90d5677781fd3d2a74493e3c Mon Sep 17 00:00:00 2001 From: Bharath Vissapragada Date: Fri, 1 Feb 2019 19:23:12 -0800 Subject: [PATCH] Repro of IMPALA-7961 Change-Id: Id0c84e2b3faf3d5ab8dcddec20719cfdf635c273 --- fe/src/main/java/org/apache/impala/analysis/TableDef.java | 3 ++- fe/src/main/java/org/apache/impala/catalog/TopicUpdateLog.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/fe/src/main/java/org/apache/impala/analysis/TableDef.java b/fe/src/main/java/org/apache/impala/analysis/TableDef.java index 0c79083..86c4c28 100644 --- a/fe/src/main/java/org/apache/impala/analysis/TableDef.java +++ b/fe/src/main/java/org/apache/impala/analysis/TableDef.java @@ -217,10 +217,11 @@ class TableDef { analyzeColumnDefs(analyzer); analyzePrimaryKeys(); + /* if (analyzer.dbContainsTable(getTblName().getDb(), getTbl(), Privilege.CREATE) && !getIfNotExists()) { throw new AnalysisException(Analyzer.TBL_ALREADY_EXISTS_ERROR_MSG + getTblName()); - } + }*/ analyzer.addAccessEvent(new TAccessEvent(fqTableName_.toString(), TCatalogObjectType.TABLE, Privilege.CREATE.toString())); diff --git a/fe/src/main/java/org/apache/impala/catalog/TopicUpdateLog.java b/fe/src/main/java/org/apache/impala/catalog/TopicUpdateLog.java index 779d8f7..8ba8f1b 100644 --- a/fe/src/main/java/org/apache/impala/catalog/TopicUpdateLog.java +++ b/fe/src/main/java/org/apache/impala/catalog/TopicUpdateLog.java @@ -40,7 +40,7 @@ public class TopicUpdateLog { private static final Logger LOG = Logger.getLogger(TopicUpdateLog.class); // Frequency at which the entries of the topic update log are garbage collected. // An entry may survive for (2 * TOPIC_UPDATE_LOG_GC_FREQUENCY) - 1 topic updates. - private final static int TOPIC_UPDATE_LOG_GC_FREQUENCY = 1000; + private final static int TOPIC_UPDATE_LOG_GC_FREQUENCY = 1; // Number of topic updates left to trigger a gc of topic update log entries. private int numTopicUpdatesToGc_ = TOPIC_UPDATE_LOG_GC_FREQUENCY; @@ -104,6 +104,7 @@ public class TopicUpdateLog { return; } if (numTopicUpdatesToGc_ == 0) { + LOG.info("GC topics started. pending items: " + topicLogEntries_.size()); if (LOG.isTraceEnabled()) { LOG.trace("Topic update log GC started."); } -- 1.9.1