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

dlmarion pushed a commit to branch elasticity
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/elasticity by this push:
     new 5cf9953142 Fixed MemoryStarvedScanIT timeout (#4270)
5cf9953142 is described below

commit 5cf99531425ccde5199bc2de344a5a6cce26baa5
Author: Dave Marion <dlmar...@apache.org>
AuthorDate: Thu Feb 15 16:22:35 2024 -0500

    Fixed MemoryStarvedScanIT timeout (#4270)
    
    MemoryStarvedScanIT was timing out because the IT was deleting
    tables as part of the test and scans on the new FATE table were
    being blocked because of the low memory condition. Adjusted the
    check for whether the table is a user table or not to include
    all tables in the accumulo namespace.
---
 .../src/main/java/org/apache/accumulo/tserver/tablet/TabletBase.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/TabletBase.java
 
b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/TabletBase.java
index 28ad0e0744..ff67ed0469 100644
--- 
a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/TabletBase.java
+++ 
b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/TabletBase.java
@@ -42,6 +42,7 @@ import 
org.apache.accumulo.core.iterators.SortedKeyValueIterator;
 import org.apache.accumulo.core.iterators.YieldCallback;
 import 
org.apache.accumulo.core.iteratorsImpl.system.IterationInterruptedException;
 import org.apache.accumulo.core.iteratorsImpl.system.SourceSwitchingIterator;
+import org.apache.accumulo.core.metadata.AccumuloTable;
 import org.apache.accumulo.core.metadata.StoredTabletFile;
 import org.apache.accumulo.core.metadata.schema.DataFileValue;
 import org.apache.accumulo.core.sample.impl.SamplerConfigurationImpl;
@@ -92,7 +93,7 @@ public abstract class TabletBase {
     this.context = server.getContext();
     this.server = server;
     this.extent = extent;
-    this.isUserTable = !extent.isMeta();
+    this.isUserTable = !AccumuloTable.allTableIds().contains(extent.tableId());
 
     TableConfiguration tblConf = 
context.getTableConfiguration(extent.tableId());
     if (tblConf == null) {

Reply via email to