Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ public void stop() {

private enum ExecutorSingleton {
INSTANCE;
private final ScheduledExecutorService scheduler = new ScheduledThreadPoolExecutor(1,
private transient final ScheduledExecutorService scheduler = new ScheduledThreadPoolExecutor(1,
new ThreadPoolExecutorThreadFactory("HBase-Metrics2-"));
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7812,11 +7812,15 @@ public Result append(Append mutate, long nonceGroup, long nonce) throws IOExcept
for (Map.Entry<Store, List<Cell>> entry : removedCellsForMemStore.entrySet()) {
Store currStore = entry.getKey();
for (Cell cell: entry.getValue()) {
CellUtil.setSequenceId(cell, walKey.getWriteEntry().getWriteNumber());
if (we != null) {
CellUtil.setSequenceId(cell, we.getWriteNumber());
}
currStore.add(cell);
}
}
if (we != null) mvcc.complete(we);
if (we != null) {
mvcc.complete(we);
}
} else if (we != null) {
mvcc.completeAndWait(we);
}
Expand Down Expand Up @@ -8042,20 +8046,27 @@ private Result doIncrement(Increment increment, long nonceGroup, long nonce) thr
rowLock.release();
}
// if the wal sync was unsuccessful, remove keys from memstore
WriteEntry we = walKey != null ? walKey.getWriteEntry() : null;
if (doRollBackMemstore) {
for (Map.Entry<Store, List<Cell>> entry : forMemStore.entrySet()) {
rollbackMemstore(entry.getKey(), entry.getValue());
}
for (Map.Entry<Store, List<Cell>> entry : removedCellsForMemStore.entrySet()) {
Store currStore = entry.getKey();
for (Cell cell : entry.getValue()) {
CellUtil.setSequenceId(cell, walKey.getWriteEntry().getWriteNumber());
if (we != null) {
CellUtil.setSequenceId(cell, we.getWriteNumber());
}
currStore.add(cell);
}
}
if (walKey != null) mvcc.complete(walKey.getWriteEntry());
if (we != null) {
mvcc.complete(we);
}
} else {
if (walKey != null) mvcc.completeAndWait(walKey.getWriteEntry());
if (we != null) {
mvcc.completeAndWait(we);
}
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2806,10 +2806,14 @@ private void removeCompactedfiles(Collection<StoreFile> compactedfiles)
// Just close and return
filesToRemove.add(file);
} else {
LOG.info("Can't archive compacted file " + file.getPath()
if (r != null) {
LOG.info("Can't archive compacted file " + file.getPath()
+ " because of either isCompactedAway=" + r.isCompactedAway()
+ " or file has reference, isReferencedInReads=" + r.isReferencedInReads()
+ ", refCount=" + r.getRefCount() + ", skipping for now.");
} else {
LOG.info("Can't archive compacted file " + file.getPath() + ", skipping for now.");
}
}
} catch (Exception e) {
LOG.error(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,6 +35,7 @@
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Random;
import java.util.Set;
import java.util.TreeSet;
Expand Down Expand Up @@ -1089,7 +1090,8 @@ public void run() {
}
}
Map<String, AtomicLong> actualReadTableLatency = regionSink.getReadLatencyMap();
for (String tableName : this.configuredReadTableTimeouts.keySet()) {
for (Entry<String, Long> entry : this.configuredReadTableTimeouts.entrySet()) {
String tableName = entry.getKey();
if (actualReadTableLatency.containsKey(tableName)) {
Long actual = actualReadTableLatency.get(tableName).longValue();
Long configured = this.configuredReadTableTimeouts.get(tableName);
Expand Down