diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileInfo.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileInfo.java index 1dd257379534..330ef6fed003 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileInfo.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileInfo.java @@ -386,7 +386,7 @@ private HFileContext createHFileContext(Path path, .withHBaseCheckSum(true) .withHFileName(path.getName()) .withCompression(trailer.getCompressionCodec()) - .withCellComparator(trailer.createComparator(trailer.getComparatorClassName())); + .withCellComparator(FixedFileTrailer.createComparator(trailer.getComparatorClassName())); // Check for any key material available byte[] keyBytes = trailer.getEncryptionKey(); if (keyBytes != null) { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFilePrettyPrinter.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFilePrettyPrinter.java index 6256e6de8e57..93d85af677b8 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFilePrettyPrinter.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFilePrettyPrinter.java @@ -291,7 +291,7 @@ public int processFile(Path file, boolean checkRootDir) throws IOException { if (checkRootDir) { Path rootPath = CommonFSUtils.getRootDir(getConf()); - String rootString = rootPath + rootPath.SEPARATOR; + String rootString = rootPath + Path.SEPARATOR; if (!file.toString().startsWith(rootString)) { // First we see if fully-qualified URI matches the root dir. It might // also be an absolute path in the same filesystem, so we prepend the FS diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CompactingMemStore.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CompactingMemStore.java index 64c2c53ec069..8ffe7b30d365 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CompactingMemStore.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CompactingMemStore.java @@ -501,7 +501,7 @@ private ThreadPoolExecutor getPool() { @VisibleForTesting protected boolean shouldFlushInMemory(MutableSegment currActive, Cell cellToAdd, MemStoreSizing memstoreSizing) { - long cellSize = currActive.getCellLength(cellToAdd); + long cellSize = MutableSegment.getCellLength(cellToAdd); long segmentDataSize = currActive.getDataSize(); while (segmentDataSize + cellSize < inmemoryFlushSize || inWalReplay) { // when replaying edits from WAL there is no need in in-memory flush regardless the size diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreLABImpl.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreLABImpl.java index 596aa87d10c9..7951c72b0da4 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreLABImpl.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreLABImpl.java @@ -377,7 +377,7 @@ public Chunk getNewExternalChunk(ChunkCreator.ChunkType chunkType) { */ @Override public Chunk getNewExternalChunk(int size) { - int allocSize = size + ChunkCreator.getInstance().SIZEOF_CHUNK_HEADER; + int allocSize = size + ChunkCreator.SIZEOF_CHUNK_HEADER; if (allocSize <= ChunkCreator.getInstance().getChunkSize()) { return getNewExternalChunk(ChunkCreator.ChunkType.DATA_CHUNK); } else { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java index e50005a2339a..72cc5e82b699 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java @@ -155,7 +155,7 @@ protected void postFinish() { private int getBatchEntrySizeExcludeBulkLoad(WALEntryBatch entryBatch) { int totalSize = 0; for(Entry entry : entryBatch.getWalEntries()) { - totalSize += entryReader.getEntrySizeExcludeBulkLoad(entry); + totalSize += ReplicationSourceWALReader.getEntrySizeExcludeBulkLoad(entry); } return totalSize; } diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessController.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessController.java index 292f1ab6c316..858afde8d01d 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessController.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/AccessController.java @@ -2587,7 +2587,7 @@ private void preHasUserPermissions(User caller, String userName, List regions) { path.toUri().getPath() + " " + tableName); } } -} \ No newline at end of file +}