Skip to content
Merged
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
3 changes: 3 additions & 0 deletions assemble/conf/log4j2.properties
Original file line number Diff line number Diff line change
Expand Up @@ -41,5 +41,8 @@ logger.shell.level = info
logger.zookeeper.name = org.apache.zookeeper
logger.zookeeper.level = error

logger.hadoop.name = org.apache.hadoop
logger.hadoop.level = warn

rootLogger.level = info
rootLogger.appenderRef.console.ref = STDERR
Original file line number Diff line number Diff line change
Expand Up @@ -520,7 +520,7 @@ Each key is the name of the pool (can be assigned any string). Each value is a J
operations and whose value is a pool size for those operations.
""", "4.0.0"),
@Deprecated(since = "4.0.0")
MANAGER_FATE_THREADPOOL_SIZE("manager.fate.threadpool.size", "64",
MANAGER_FATE_THREADPOOL_SIZE("manager.fate.threadpool.size", "",
PropertyType.FATE_THREADPOOL_SIZE, """
Previously, the number of threads used to run fault-tolerant executions (FATE). \
This is no longer used in 4.0+. %s and %s are the replacement and must be \
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -569,10 +569,12 @@ private static class FateThreadPoolSize implements Predicate<String> {

@Override
public boolean test(String s) {
log.warn(
"The manager fate thread pool size property is no longer used. See the {} and {} for "
+ "the replacements to this property.",
ValidUserFateConfig.NAME, ValidMetaFateConfig.NAME);
if (!s.isEmpty()) {
log.warn(
"The manager fate thread pool size property is no longer used. See the {} and {} for "
+ "the replacements to this property.",
ValidUserFateConfig.NAME, ValidMetaFateConfig.NAME);
}
return true;
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -284,7 +284,7 @@ private CompressionCodec createNewCodec(final String codecClazzProp, final Strin
clazz = System.getProperty(codecClazzProp, getConf().get(codecClazzProp, defaultClazz));
}
try {
LOG.info("Trying to load codec class {}", clazz);
LOG.debug("Trying to load codec class {}", clazz);
Configuration config = new Configuration(getConf());
updateBuffer(config, bufferSizeConfigOpt, bufferSize);
return (CompressionCodec) ReflectionUtils.newInstance(Class.forName(clazz), config);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -336,10 +336,10 @@ public static void ensureDataVersionCompatible(int dataVersion) {
}

public void waitForZookeeperAndHdfs() {
log.info("Attempting to talk to zookeeper");
log.debug("Attempting to talk to zookeeper");
// Next line blocks until connection is established
getZooSession();
log.info("ZooKeeper connected and initialized, attempting to talk to HDFS");
log.debug("ZooKeeper connected and initialized, attempting to talk to HDFS");
long sleep = 1000;
int unknownHostTries = 3;
while (true) {
Expand Down Expand Up @@ -370,12 +370,12 @@ public void waitForZookeeperAndHdfs() {
throw e;
}
}
log.info("Backing off due to failure; current sleep period is {} seconds", sleep / 1000.);
log.debug("Backing off due to failure; current sleep period is {} seconds", sleep / 1000.);
sleepUninterruptibly(sleep, TimeUnit.MILLISECONDS);
/* Back off to give transient failures more time to clear. */
sleep = Math.min(MINUTES.toMillis(1), sleep * 2);
}
log.info("Connected to HDFS");
log.debug("Connected to HDFS");
}

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,7 @@ public void process(final WatchedEvent event) {
// terminal - never coming back.
case Expired:
case Closed:
log.info("ZooKeeper connection closed event received");
log.debug("ZooKeeper connection closed event received");
zkReadyMonitor.clearReady();
zkReadyMonitor.setClosed(); // terminal condition
executorService.execute(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -120,9 +120,9 @@ public CommandGroup commandGroup() {
public void execute(JCommander cl, ViewerOpts opts) throws Exception {
nullWatcher = new NullWatcher(new ReadyMonitor(ZooInfoViewer.class.getSimpleName(), 20_000L));

log.info("print ids map: {}", opts.printIdMap);
log.info("print properties: {}", opts.printProps);
log.info("print instances: {}", opts.printInstanceIds);
log.debug("print ids map: {}", opts.printIdMap);
log.debug("print properties: {}", opts.printProps);
log.debug("print instances: {}", opts.printInstanceIds);

generateReport(getServerContext(), opts);
}
Expand Down