Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-15931 : Fix non-static inner classes for better memory management (#2830). Contributed by Viraj Jasani 

Signed-off-by: Mingliang Liu <liuml07@apache.org>
This commit is contained in:
Viraj Jasani 2021-04-02 05:04:31 +05:30 committed by Mingliang Liu
parent 93517ba9bc
commit 5458ebf607
No known key found for this signature in database
GPG Key ID: BC2FB8C6908A0C16
6 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/MiniRouterDFSCluster.java
View File

@ -140,7 +140,7 @@ public class MiniRouterDFSCluster {
/** /**
* Router context. * Router context.
*/ */
public class RouterContext { public static class RouterContext {
private Router router; private Router router;
private FileContext fileContext; private FileContext fileContext;
private String nameserviceId; private String nameserviceId;

2
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/common/blockaliasmap/impl/InMemoryLevelDBAliasMapClient.java
View File

@ -130,7 +130,7 @@ public class InMemoryLevelDBAliasMapClient extends BlockAliasMap<FileRegion>
} }
} }
class LevelDbWriter extends BlockAliasMap.Writer<FileRegion> { static class LevelDbWriter extends BlockAliasMap.Writer<FileRegion> {
private InMemoryAliasMapProtocol aliasMap; private InMemoryAliasMapProtocol aliasMap;

4
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/RamDiskReplicaLruTracker.java
View File

@ -35,7 +35,7 @@ import java.util.*;
@InterfaceStability.Unstable @InterfaceStability.Unstable
public class RamDiskReplicaLruTracker extends RamDiskReplicaTracker { public class RamDiskReplicaLruTracker extends RamDiskReplicaTracker {
private class RamDiskReplicaLru extends RamDiskReplica { private static class RamDiskReplicaLru extends RamDiskReplica {
long lastUsedTime; long lastUsedTime;
private RamDiskReplicaLru(String bpid, long blockId, private RamDiskReplicaLru(String bpid, long blockId,
@ -88,7 +88,7 @@ public class RamDiskReplicaLruTracker extends RamDiskReplicaTracker {
} }
RamDiskReplicaLru ramDiskReplicaLru = RamDiskReplicaLru ramDiskReplicaLru =
new RamDiskReplicaLru(bpid, blockId, transientVolume, new RamDiskReplicaLru(bpid, blockId, transientVolume,
lockedBytesReserved); lockedBytesReserved);
map.put(blockId, ramDiskReplicaLru); map.put(blockId, ramDiskReplicaLru);
replicasNotPersisted.add(ramDiskReplicaLru); replicasNotPersisted.add(ramDiskReplicaLru);
} }

2
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ReencryptionHandler.java
View File

@ -835,7 +835,7 @@ public class ReencryptionHandler implements Runnable {
} }
} }
private class ZoneTraverseInfo extends TraverseInfo { private static class ZoneTraverseInfo extends TraverseInfo {
private String ezKeyVerName; private String ezKeyVerName;
ZoneTraverseInfo(String ezKeyVerName) { ZoneTraverseInfo(String ezKeyVerName) {

20
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/tools/DebugAdmin.java
View File

@ -64,7 +64,7 @@ public class DebugAdmin extends Configured implements Tool {
/** /**
* All the debug commands we can run. * All the debug commands we can run.
*/ */
private DebugCommand DEBUG_COMMANDS[] = { private final DebugCommand[] DEBUG_COMMANDS = {
new VerifyMetaCommand(), new VerifyMetaCommand(),
new ComputeMetaCommand(), new ComputeMetaCommand(),
new RecoverLeaseCommand(), new RecoverLeaseCommand(),
@ -74,7 +74,7 @@ public class DebugAdmin extends Configured implements Tool {
/** /**
* The base class for debug commands. * The base class for debug commands.
*/ */
private abstract class DebugCommand { private abstract static class DebugCommand {
final String name; final String name;
final String usageText; final String usageText;
final String helpText; final String helpText;
@ -93,15 +93,15 @@ public class DebugAdmin extends Configured implements Tool {
/** /**
* The command for verifying a block metadata file and possibly block file. * The command for verifying a block metadata file and possibly block file.
*/ */
private class VerifyMetaCommand extends DebugCommand { private static class VerifyMetaCommand extends DebugCommand {
VerifyMetaCommand() { VerifyMetaCommand() {
super("verifyMeta", super("verifyMeta",
"verifyMeta -meta <metadata-file> [-block <block-file>]", "verifyMeta -meta <metadata-file> [-block <block-file>]",
" Verify HDFS metadata and block files. If a block file is specified, we" + " Verify HDFS metadata and block files. If a block file is specified, we" +
System.lineSeparator() + System.lineSeparator() +
" will verify that the checksums in the metadata file match the block" + " will verify that the checksums in the metadata file match the block" +
System.lineSeparator() + System.lineSeparator() +
" file."); " file.");
} }
int run(List<String> args) throws IOException { int run(List<String> args) throws IOException {
@ -209,7 +209,7 @@ public class DebugAdmin extends Configured implements Tool {
/** /**
* The command for verifying a block metadata file and possibly block file. * The command for verifying a block metadata file and possibly block file.
*/ */
private class ComputeMetaCommand extends DebugCommand { private static class ComputeMetaCommand extends DebugCommand {
ComputeMetaCommand() { ComputeMetaCommand() {
super("computeMeta", super("computeMeta",
"computeMeta -block <block-file> -out <output-metadata-file>", "computeMeta -block <block-file> -out <output-metadata-file>",

2
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/MiniDFSCluster.java
View File

@ -562,7 +562,7 @@ public class MiniDFSCluster implements AutoCloseable {
builder.useConfiguredTopologyMappingClass); builder.useConfiguredTopologyMappingClass);
} }
public class DataNodeProperties { public static class DataNodeProperties {
final DataNode datanode; final DataNode datanode;
final Configuration conf; final Configuration conf;
String[] dnArgs; String[] dnArgs;