Revert "Add check to not flush when table is being deleted. (#1887)"
This reverts commit b8dac789fbf637e16992257f668ef6aaeeff1a83.
diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Tablet.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Tablet.java
index 008e645..cf08e26 100644
--- a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Tablet.java
+++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/Tablet.java
@@ -68,7 +68,6 @@
import org.apache.accumulo.core.iterators.YieldCallback;
import org.apache.accumulo.core.iteratorsImpl.system.SourceSwitchingIterator;
import org.apache.accumulo.core.logging.TabletLogger;
-import org.apache.accumulo.core.master.state.tables.TableState;
import org.apache.accumulo.core.master.thrift.BulkImportState;
import org.apache.accumulo.core.metadata.MetadataTable;
import org.apache.accumulo.core.metadata.StoredTabletFile;
@@ -880,11 +879,6 @@
if (isClosed()) {
return false;
}
- TableState tableState = context.getTableManager().getTableState(extent.tableId());
- if (tableState.equals(TableState.DELETING)) {
- log.debug("Table {} is being deleted so don't flush {}", extent.tableId(), extent);
- return false;
- }
// get the flush id before the new memmap is made available for write
long flushId;
