Revert "HADOOP-11602. Fix toUpperCase/toLowerCase to use Locale.ENGLISH. (ozawa)"
This reverts commit 946456c6d8
.
Conflicts:
hadoop-common-project/hadoop-common/CHANGES.txt
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/QuotaByStorageTypeEntry.java
This commit is contained in:
parent
b53fd7163b
commit
9cedad11d8
@ -21,7 +21,6 @@
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
|
||||
class StabilityOptions {
|
||||
public static final String STABLE_OPTION = "-stable";
|
||||
@ -29,7 +28,7 @@ class StabilityOptions {
|
||||
public static final String UNSTABLE_OPTION = "-unstable";
|
||||
|
||||
public static Integer optionLength(String option) {
|
||||
String opt = option.toLowerCase(Locale.ENGLISH);
|
||||
String opt = option.toLowerCase();
|
||||
if (opt.equals(UNSTABLE_OPTION)) return 1;
|
||||
if (opt.equals(EVOLVING_OPTION)) return 1;
|
||||
if (opt.equals(STABLE_OPTION)) return 1;
|
||||
@ -39,7 +38,7 @@ public static Integer optionLength(String option) {
|
||||
public static void validOptions(String[][] options,
|
||||
DocErrorReporter reporter) {
|
||||
for (int i = 0; i < options.length; i++) {
|
||||
String opt = options[i][0].toLowerCase(Locale.ENGLISH);
|
||||
String opt = options[i][0].toLowerCase();
|
||||
if (opt.equals(UNSTABLE_OPTION)) {
|
||||
RootDocProcessor.stability = UNSTABLE_OPTION;
|
||||
} else if (opt.equals(EVOLVING_OPTION)) {
|
||||
|
@ -14,7 +14,6 @@
|
||||
package org.apache.hadoop.security.authentication.server;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.util.Locale;
|
||||
import java.util.Properties;
|
||||
import javax.servlet.ServletException;
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
@ -69,8 +68,7 @@ public void init(Properties config) throws ServletException {
|
||||
NON_BROWSER_USER_AGENTS, NON_BROWSER_USER_AGENTS_DEFAULT)
|
||||
.split("\\W*,\\W*");
|
||||
for (int i = 0; i < nonBrowserUserAgents.length; i++) {
|
||||
nonBrowserUserAgents[i] =
|
||||
nonBrowserUserAgents[i].toLowerCase(Locale.ENGLISH);
|
||||
nonBrowserUserAgents[i] = nonBrowserUserAgents[i].toLowerCase();
|
||||
}
|
||||
}
|
||||
|
||||
@ -122,7 +120,7 @@ protected boolean isBrowser(String userAgent) {
|
||||
if (userAgent == null) {
|
||||
return false;
|
||||
}
|
||||
userAgent = userAgent.toLowerCase(Locale.ENGLISH);
|
||||
userAgent = userAgent.toLowerCase();
|
||||
boolean isBrowser = true;
|
||||
for (String nonBrowserUserAgent : nonBrowserUserAgents) {
|
||||
if (userAgent.contains(nonBrowserUserAgent)) {
|
||||
|
@ -21,7 +21,6 @@
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.regex.Pattern;
|
||||
|
||||
import org.apache.directory.server.kerberos.shared.keytab.Keytab;
|
||||
@ -59,25 +58,24 @@ public void testGetServerPrincipal() throws IOException {
|
||||
|
||||
// send null hostname
|
||||
Assert.assertEquals("When no hostname is sent",
|
||||
service + "/" + localHostname.toLowerCase(Locale.ENGLISH),
|
||||
service + "/" + localHostname.toLowerCase(),
|
||||
KerberosUtil.getServicePrincipal(service, null));
|
||||
// send empty hostname
|
||||
Assert.assertEquals("When empty hostname is sent",
|
||||
service + "/" + localHostname.toLowerCase(Locale.ENGLISH),
|
||||
service + "/" + localHostname.toLowerCase(),
|
||||
KerberosUtil.getServicePrincipal(service, ""));
|
||||
// send 0.0.0.0 hostname
|
||||
Assert.assertEquals("When 0.0.0.0 hostname is sent",
|
||||
service + "/" + localHostname.toLowerCase(Locale.ENGLISH),
|
||||
service + "/" + localHostname.toLowerCase(),
|
||||
KerberosUtil.getServicePrincipal(service, "0.0.0.0"));
|
||||
// send uppercase hostname
|
||||
Assert.assertEquals("When uppercase hostname is sent",
|
||||
service + "/" + testHost.toLowerCase(Locale.ENGLISH),
|
||||
service + "/" + testHost.toLowerCase(),
|
||||
KerberosUtil.getServicePrincipal(service, testHost));
|
||||
// send lowercase hostname
|
||||
Assert.assertEquals("When lowercase hostname is sent",
|
||||
service + "/" + testHost.toLowerCase(Locale.ENGLISH),
|
||||
KerberosUtil.getServicePrincipal(
|
||||
service, testHost.toLowerCase(Locale.ENGLISH)));
|
||||
service + "/" + testHost.toLowerCase(),
|
||||
KerberosUtil.getServicePrincipal(service, testHost.toLowerCase()));
|
||||
}
|
||||
|
||||
@Test
|
||||
|
@ -405,8 +405,6 @@ Trunk (Unreleased)
|
||||
|
||||
HADOOP-11585. Fix formatting in Tracing.md (Masatake Iwasaki via aw)
|
||||
|
||||
HADOOP-11602. Fix toUpperCase/toLowerCase to use Locale.ENGLISH. (ozawa)
|
||||
|
||||
HADOOP-11625. Minor fixes to command manual & SLA doc (aw)
|
||||
|
||||
OPTIMIZATIONS
|
||||
|
@ -46,7 +46,6 @@
|
||||
import java.util.LinkedList;
|
||||
import java.util.List;
|
||||
import java.util.ListIterator;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.Map.Entry;
|
||||
import java.util.Properties;
|
||||
@ -1452,7 +1451,7 @@ public boolean getBoolean(String name, boolean defaultValue) {
|
||||
return defaultValue;
|
||||
}
|
||||
|
||||
valueString = valueString.toLowerCase(Locale.ENGLISH);
|
||||
valueString = valueString.toLowerCase();
|
||||
|
||||
if ("true".equals(valueString))
|
||||
return true;
|
||||
|
@ -18,7 +18,6 @@
|
||||
|
||||
package org.apache.hadoop.crypto;
|
||||
|
||||
import java.util.Locale;
|
||||
import org.apache.hadoop.classification.InterfaceAudience;
|
||||
|
||||
/**
|
||||
@ -98,7 +97,7 @@ public String getConfigSuffix() {
|
||||
String[] parts = name.split("/");
|
||||
StringBuilder suffix = new StringBuilder();
|
||||
for (String part : parts) {
|
||||
suffix.append(".").append(part.toLowerCase(Locale.ENGLISH));
|
||||
suffix.append(".").append(part.toLowerCase());
|
||||
}
|
||||
|
||||
return suffix.toString();
|
||||
|
@ -53,7 +53,6 @@
|
||||
import java.util.Enumeration;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.locks.Lock;
|
||||
import java.util.concurrent.locks.ReadWriteLock;
|
||||
@ -423,7 +422,7 @@ public Metadata getMetadata(String name) throws IOException {
|
||||
@Override
|
||||
public KeyVersion createKey(String name, byte[] material,
|
||||
Options options) throws IOException {
|
||||
Preconditions.checkArgument(name.equals(name.toLowerCase(Locale.ENGLISH)),
|
||||
Preconditions.checkArgument(name.equals(name.toLowerCase()),
|
||||
"Uppercase key names are unsupported: %s", name);
|
||||
writeLock.lock();
|
||||
try {
|
||||
|
@ -33,7 +33,6 @@
|
||||
import java.util.Iterator;
|
||||
import java.util.LinkedList;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.NoSuchElementException;
|
||||
import java.util.ServiceLoader;
|
||||
@ -2796,10 +2795,8 @@ static class Key {
|
||||
}
|
||||
|
||||
Key(URI uri, Configuration conf, long unique) throws IOException {
|
||||
scheme = uri.getScheme() == null ?
|
||||
"" : uri.getScheme().toLowerCase(Locale.ENGLISH);
|
||||
authority = uri.getAuthority() == null ?
|
||||
"" : uri.getAuthority().toLowerCase(Locale.ENGLISH);
|
||||
scheme = uri.getScheme()==null?"":uri.getScheme().toLowerCase();
|
||||
authority = uri.getAuthority()==null?"":uri.getAuthority().toLowerCase();
|
||||
this.unique = unique;
|
||||
|
||||
this.ugi = UserGroupInformation.getCurrentUser();
|
||||
|
@ -21,7 +21,6 @@
|
||||
import java.util.Arrays;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
|
||||
import org.apache.hadoop.classification.InterfaceAudience;
|
||||
import org.apache.hadoop.classification.InterfaceStability;
|
||||
@ -79,7 +78,7 @@ public static StorageType parseStorageType(int i) {
|
||||
}
|
||||
|
||||
public static StorageType parseStorageType(String s) {
|
||||
return StorageType.valueOf(s.toUpperCase(Locale.ENGLISH));
|
||||
return StorageType.valueOf(s.toUpperCase());
|
||||
}
|
||||
|
||||
private static List<StorageType> getNonTransientTypes() {
|
||||
|
@ -20,7 +20,6 @@
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collection;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
|
||||
import com.google.common.base.Objects;
|
||||
|
||||
@ -107,7 +106,7 @@ public String toString() {
|
||||
sb.append("default:");
|
||||
}
|
||||
if (type != null) {
|
||||
sb.append(type.toString().toLowerCase(Locale.ENGLISH));
|
||||
sb.append(type.toString().toLowerCase());
|
||||
}
|
||||
sb.append(':');
|
||||
if (name != null) {
|
||||
@ -264,8 +263,7 @@ public static AclEntry parseAclEntry(String aclStr,
|
||||
|
||||
AclEntryType aclType = null;
|
||||
try {
|
||||
aclType = Enum.valueOf(
|
||||
AclEntryType.class, split[index].toUpperCase(Locale.ENGLISH));
|
||||
aclType = Enum.valueOf(AclEntryType.class, split[index].toUpperCase());
|
||||
builder.setType(aclType);
|
||||
index++;
|
||||
} catch (IllegalArgumentException iae) {
|
||||
|
@ -19,7 +19,6 @@
|
||||
|
||||
import java.io.IOException;
|
||||
import java.util.Deque;
|
||||
import java.util.Locale;
|
||||
|
||||
import org.apache.hadoop.fs.GlobPattern;
|
||||
import org.apache.hadoop.fs.shell.PathData;
|
||||
@ -74,7 +73,7 @@ public void addArguments(Deque<String> args) {
|
||||
public void prepare() throws IOException {
|
||||
String argPattern = getArgument(1);
|
||||
if (!caseSensitive) {
|
||||
argPattern = argPattern.toLowerCase(Locale.ENGLISH);
|
||||
argPattern = argPattern.toLowerCase();
|
||||
}
|
||||
globPattern = new GlobPattern(argPattern);
|
||||
}
|
||||
@ -83,7 +82,7 @@ public void prepare() throws IOException {
|
||||
public Result apply(PathData item, int depth) throws IOException {
|
||||
String name = getPath(item).getName();
|
||||
if (!caseSensitive) {
|
||||
name = name.toLowerCase(Locale.ENGLISH);
|
||||
name = name.toLowerCase();
|
||||
}
|
||||
if (globPattern.matches(name)) {
|
||||
return Result.PASS;
|
||||
|
@ -65,10 +65,10 @@ private void addCodec(CompressionCodec codec) {
|
||||
codecsByClassName.put(codec.getClass().getCanonicalName(), codec);
|
||||
|
||||
String codecName = codec.getClass().getSimpleName();
|
||||
codecsByName.put(codecName.toLowerCase(Locale.ENGLISH), codec);
|
||||
codecsByName.put(codecName.toLowerCase(), codec);
|
||||
if (codecName.endsWith("Codec")) {
|
||||
codecName = codecName.substring(0, codecName.length() - "Codec".length());
|
||||
codecsByName.put(codecName.toLowerCase(Locale.ENGLISH), codec);
|
||||
codecsByName.put(codecName.toLowerCase(), codec);
|
||||
}
|
||||
}
|
||||
|
||||
@ -240,7 +240,7 @@ public CompressionCodec getCodecByName(String codecName) {
|
||||
CompressionCodec codec = getCodecByClassName(codecName);
|
||||
if (codec == null) {
|
||||
// trying to get the codec by name in case the name was specified instead a class
|
||||
codec = codecsByName.get(codecName.toLowerCase(Locale.ENGLISH));
|
||||
codec = codecsByName.get(codecName.toLowerCase());
|
||||
}
|
||||
return codec;
|
||||
}
|
||||
|
@ -85,12 +85,11 @@ class MetricsConfig extends SubsetConfiguration {
|
||||
private ClassLoader pluginLoader;
|
||||
|
||||
MetricsConfig(Configuration c, String prefix) {
|
||||
super(c, prefix.toLowerCase(Locale.ENGLISH), ".");
|
||||
super(c, prefix.toLowerCase(Locale.US), ".");
|
||||
}
|
||||
|
||||
static MetricsConfig create(String prefix) {
|
||||
return loadFirst(prefix, "hadoop-metrics2" + "-"
|
||||
+ prefix.toLowerCase(Locale.ENGLISH)
|
||||
return loadFirst(prefix, "hadoop-metrics2-"+ prefix.toLowerCase(Locale.US)
|
||||
+".properties", DEFAULT_FILE_NAME);
|
||||
}
|
||||
|
||||
|
@ -617,6 +617,6 @@ private InitMode initMode() {
|
||||
String m = System.getProperty(MS_INIT_MODE_KEY);
|
||||
String m2 = m == null ? System.getenv(MS_INIT_MODE_KEY) : m;
|
||||
return InitMode.valueOf((m2 == null ? InitMode.NORMAL.name() : m2)
|
||||
.toUpperCase(Locale.ENGLISH));
|
||||
.toUpperCase(Locale.US));
|
||||
}
|
||||
}
|
||||
|
@ -182,8 +182,7 @@ private static String replacePattern(String[] components, String hostname)
|
||||
if (fqdn == null || fqdn.isEmpty() || fqdn.equals("0.0.0.0")) {
|
||||
fqdn = getLocalHostName();
|
||||
}
|
||||
return components[0] + "/" + fqdn.toLowerCase(Locale.ENGLISH) + "@"
|
||||
+ components[2];
|
||||
return components[0] + "/" + fqdn.toLowerCase(Locale.US) + "@" + components[2];
|
||||
}
|
||||
|
||||
static String getLocalHostName() throws UnknownHostException {
|
||||
@ -380,7 +379,7 @@ public static Text buildTokenService(InetSocketAddress addr) {
|
||||
}
|
||||
host = addr.getAddress().getHostAddress();
|
||||
} else {
|
||||
host = addr.getHostName().toLowerCase(Locale.ENGLISH);
|
||||
host = addr.getHostName().toLowerCase();
|
||||
}
|
||||
return new Text(host + ":" + addr.getPort());
|
||||
}
|
||||
|
@ -19,7 +19,6 @@
|
||||
|
||||
import java.net.InetAddress;
|
||||
import java.net.UnknownHostException;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.TreeMap;
|
||||
|
||||
@ -139,8 +138,7 @@ static Map<String, String> getSaslProperties(Configuration conf) {
|
||||
QualityOfProtection.PRIVACY.toString());
|
||||
|
||||
for (int i=0; i < qop.length; i++) {
|
||||
qop[i] = QualityOfProtection.valueOf(
|
||||
qop[i].toUpperCase(Locale.ENGLISH)).getSaslQop();
|
||||
qop[i] = QualityOfProtection.valueOf(qop[i].toUpperCase()).getSaslQop();
|
||||
}
|
||||
|
||||
saslProps.put(Sasl.QOP, StringUtils.join(",", qop));
|
||||
|
@ -33,7 +33,6 @@
|
||||
import java.security.GeneralSecurityException;
|
||||
import java.security.KeyStore;
|
||||
import java.text.MessageFormat;
|
||||
import java.util.Locale;
|
||||
|
||||
/**
|
||||
* {@link KeyStoresFactory} implementation that reads the certificates from
|
||||
@ -95,8 +94,7 @@ public class FileBasedKeyStoresFactory implements KeyStoresFactory {
|
||||
@VisibleForTesting
|
||||
public static String resolvePropertyName(SSLFactory.Mode mode,
|
||||
String template) {
|
||||
return MessageFormat.format(
|
||||
template, mode.toString().toLowerCase(Locale.ENGLISH));
|
||||
return MessageFormat.format(template, mode.toString().toLowerCase());
|
||||
}
|
||||
|
||||
/**
|
||||
|
@ -33,7 +33,6 @@
|
||||
import java.io.IOException;
|
||||
import java.net.HttpURLConnection;
|
||||
import java.security.GeneralSecurityException;
|
||||
import java.util.Locale;
|
||||
|
||||
/**
|
||||
* Factory that creates SSLEngine and SSLSocketFactory instances using
|
||||
@ -139,7 +138,7 @@ public void init() throws GeneralSecurityException, IOException {
|
||||
private HostnameVerifier getHostnameVerifier(Configuration conf)
|
||||
throws GeneralSecurityException, IOException {
|
||||
return getHostnameVerifier(conf.get(SSL_HOSTNAME_VERIFIER_KEY, "DEFAULT").
|
||||
trim().toUpperCase(Locale.ENGLISH));
|
||||
trim().toUpperCase());
|
||||
}
|
||||
|
||||
public static HostnameVerifier getHostnameVerifier(String verifier)
|
||||
|
@ -41,7 +41,6 @@
|
||||
import java.util.Iterator;
|
||||
import java.util.LinkedList;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
import java.util.StringTokenizer;
|
||||
import java.util.TreeSet;
|
||||
@ -366,7 +365,7 @@ public void check(final String[] hosts, final String[] cns,
|
||||
buf.append('<');
|
||||
for (int i = 0; i < hosts.length; i++) {
|
||||
String h = hosts[i];
|
||||
h = h != null ? h.trim().toLowerCase(Locale.ENGLISH) : "";
|
||||
h = h != null ? h.trim().toLowerCase() : "";
|
||||
hosts[i] = h;
|
||||
if (i > 0) {
|
||||
buf.append('/');
|
||||
@ -407,7 +406,7 @@ public void check(final String[] hosts, final String[] cns,
|
||||
out:
|
||||
for (Iterator<String> it = names.iterator(); it.hasNext();) {
|
||||
// Don't trim the CN, though!
|
||||
final String cn = it.next().toLowerCase(Locale.ENGLISH);
|
||||
final String cn = it.next().toLowerCase();
|
||||
// Store CN in StringBuffer in case we need to report an error.
|
||||
buf.append(" <");
|
||||
buf.append(cn);
|
||||
@ -425,8 +424,7 @@ public void check(final String[] hosts, final String[] cns,
|
||||
acceptableCountryWildcard(cn);
|
||||
|
||||
for (int i = 0; i < hosts.length; i++) {
|
||||
final String hostName =
|
||||
hosts[i].trim().toLowerCase(Locale.ENGLISH);
|
||||
final String hostName = hosts[i].trim().toLowerCase();
|
||||
if (doWildcard) {
|
||||
match = hostName.endsWith(cn.substring(1));
|
||||
if (match && strictWithSubDomains) {
|
||||
@ -481,7 +479,7 @@ public static boolean acceptableCountryWildcard(final String cn) {
|
||||
}
|
||||
|
||||
public static boolean isLocalhost(String host) {
|
||||
host = host != null ? host.trim().toLowerCase(Locale.ENGLISH) : "";
|
||||
host = host != null ? host.trim().toLowerCase() : "";
|
||||
if (host.startsWith("::1")) {
|
||||
int x = host.lastIndexOf('%');
|
||||
if (x >= 0) {
|
||||
|
@ -23,7 +23,6 @@
|
||||
import java.util.HashMap;
|
||||
import java.util.HashSet;
|
||||
import java.util.LinkedHashMap;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.Properties;
|
||||
import java.util.Set;
|
||||
@ -170,7 +169,7 @@ public boolean managementOperation(AuthenticationToken token,
|
||||
boolean requestContinues = true;
|
||||
String op = ServletUtils.getParameter(request,
|
||||
KerberosDelegationTokenAuthenticator.OP_PARAM);
|
||||
op = (op != null) ? op.toUpperCase(Locale.ENGLISH) : null;
|
||||
op = (op != null) ? op.toUpperCase() : null;
|
||||
if (DELEGATION_TOKEN_OPS.contains(op) &&
|
||||
!request.getMethod().equals("OPTIONS")) {
|
||||
KerberosDelegationTokenAuthenticator.DelegationTokenOperation dtOp =
|
||||
|
@ -37,7 +37,6 @@
|
||||
import java.net.URL;
|
||||
import java.net.URLEncoder;
|
||||
import java.util.HashMap;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
@ -287,8 +286,8 @@ private Map doDelegationTokenOperation(URL url,
|
||||
HttpExceptionUtils.validateResponse(conn, HttpURLConnection.HTTP_OK);
|
||||
if (hasResponse) {
|
||||
String contentType = conn.getHeaderField(CONTENT_TYPE);
|
||||
contentType = (contentType != null) ?
|
||||
contentType.toLowerCase(Locale.ENGLISH) : null;
|
||||
contentType = (contentType != null) ? contentType.toLowerCase()
|
||||
: null;
|
||||
if (contentType != null &&
|
||||
contentType.contains(APPLICATION_JSON_MIME)) {
|
||||
try {
|
||||
|
@ -901,7 +901,7 @@ public static String join(CharSequence separator, String[] strings) {
|
||||
*/
|
||||
public static String camelize(String s) {
|
||||
StringBuilder sb = new StringBuilder();
|
||||
String[] words = split(s.toLowerCase(Locale.ENGLISH), ESCAPE_CHAR, '_');
|
||||
String[] words = split(s.toLowerCase(Locale.US), ESCAPE_CHAR, '_');
|
||||
|
||||
for (String word : words)
|
||||
sb.append(org.apache.commons.lang.StringUtils.capitalize(word));
|
||||
|
@ -43,7 +43,6 @@
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Random;
|
||||
import java.util.concurrent.BrokenBarrierException;
|
||||
import java.util.concurrent.CountDownLatch;
|
||||
@ -1297,7 +1296,7 @@ private static byte[] hexDumpToBytes(String hexdump) {
|
||||
|
||||
StringBuilder hexString = new StringBuilder();
|
||||
|
||||
for (String line : hexdump.toUpperCase(Locale.ENGLISH).split("\n")) {
|
||||
for (String line : hexdump.toUpperCase().split("\n")) {
|
||||
hexString.append(line.substring(0, LAST_HEX_COL).replace(" ", ""));
|
||||
}
|
||||
return StringUtils.hexStringToByte(hexString.toString());
|
||||
|
@ -41,7 +41,6 @@
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collection;
|
||||
import java.util.HashMap;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
import java.util.regex.Pattern;
|
||||
@ -182,7 +181,7 @@ static String getQOPNames (QualityOfProtection[] qops){
|
||||
StringBuilder sb = new StringBuilder();
|
||||
int i = 0;
|
||||
for (QualityOfProtection qop:qops){
|
||||
sb.append(qop.name().toLowerCase(Locale.ENGLISH));
|
||||
sb.append(qop.name().toLowerCase());
|
||||
if (++i < qops.length){
|
||||
sb.append(",");
|
||||
}
|
||||
|
@ -103,13 +103,13 @@ public void testPrincipalsWithLowerCaseHosts() throws IOException {
|
||||
String realm = "@REALM";
|
||||
String principalInConf = service + SecurityUtil.HOSTNAME_PATTERN + realm;
|
||||
String hostname = "FooHost";
|
||||
String principal = service + hostname.toLowerCase(Locale.ENGLISH) + realm;
|
||||
String principal = service + hostname.toLowerCase() + realm;
|
||||
verify(principalInConf, hostname, principal);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testLocalHostNameForNullOrWild() throws Exception {
|
||||
String local = SecurityUtil.getLocalHostName().toLowerCase(Locale.ENGLISH);
|
||||
String local = SecurityUtil.getLocalHostName().toLowerCase(Locale.US);
|
||||
assertEquals("hdfs/" + local + "@REALM",
|
||||
SecurityUtil.getServerPrincipal("hdfs/_HOST@REALM", (String)null));
|
||||
assertEquals("hdfs/" + local + "@REALM",
|
||||
@ -260,7 +260,7 @@ void runBadPortPermutes(String arg, boolean validIfPosPort) {
|
||||
//LOG.info("address:"+addr+" host:"+host+" ip:"+ip+" port:"+port);
|
||||
|
||||
SecurityUtil.setTokenServiceUseIp(useIp);
|
||||
String serviceHost = useIp ? ip : host.toLowerCase(Locale.ENGLISH);
|
||||
String serviceHost = useIp ? ip : host.toLowerCase();
|
||||
|
||||
Token<?> token = new Token<TokenIdentifier>();
|
||||
Text service = new Text(serviceHost+":"+port);
|
||||
|
@ -41,7 +41,6 @@
|
||||
import java.util.Collection;
|
||||
import java.util.ConcurrentModificationException;
|
||||
import java.util.LinkedHashSet;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
|
||||
import static org.apache.hadoop.fs.CommonConfigurationKeys.HADOOP_USER_GROUP_METRICS_PERCENTILES_INTERVALS;
|
||||
@ -214,7 +213,7 @@ public void testGetServerSideGroups() throws IOException,
|
||||
userName = userName.substring(sp + 1);
|
||||
}
|
||||
// user names are case insensitive on Windows. Make consistent
|
||||
userName = userName.toLowerCase(Locale.ENGLISH);
|
||||
userName = userName.toLowerCase();
|
||||
}
|
||||
// get the groups
|
||||
pp = Runtime.getRuntime().exec(Shell.WINDOWS ?
|
||||
@ -234,7 +233,7 @@ public void testGetServerSideGroups() throws IOException,
|
||||
String loginUserName = login.getShortUserName();
|
||||
if(Shell.WINDOWS) {
|
||||
// user names are case insensitive on Windows. Make consistent
|
||||
loginUserName = loginUserName.toLowerCase(Locale.ENGLISH);
|
||||
loginUserName = loginUserName.toLowerCase();
|
||||
}
|
||||
assertEquals(userName, loginUserName);
|
||||
|
||||
|
@ -27,7 +27,6 @@
|
||||
import java.text.DateFormat;
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.util.Date;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
|
||||
import org.junit.runner.notification.Failure;
|
||||
@ -94,8 +93,7 @@ static String buildThreadDump() {
|
||||
thread.getPriority(),
|
||||
thread.getId(),
|
||||
Thread.State.WAITING.equals(thread.getState()) ?
|
||||
"in Object.wait()" :
|
||||
thread.getState().name().toLowerCase(Locale.ENGLISH),
|
||||
"in Object.wait()" : thread.getState().name().toLowerCase(),
|
||||
Thread.State.WAITING.equals(thread.getState()) ?
|
||||
"WAITING (on object monitor)" : thread.getState()));
|
||||
for (StackTraceElement stackTraceElement : e.getValue()) {
|
||||
|
@ -27,7 +27,6 @@
|
||||
import java.io.FileOutputStream;
|
||||
import java.io.FileWriter;
|
||||
import java.io.IOException;
|
||||
import java.util.Locale;
|
||||
|
||||
import org.apache.commons.io.FileUtils;
|
||||
import org.apache.commons.logging.Log;
|
||||
@ -383,10 +382,8 @@ private void chown(String userGroup, File file) throws IOException {
|
||||
private void assertOwners(File file, String expectedUser,
|
||||
String expectedGroup) throws IOException {
|
||||
String [] args = lsF(file).trim().split("[\\|]");
|
||||
assertEquals(expectedUser.toLowerCase(Locale.ENGLISH),
|
||||
args[2].toLowerCase(Locale.ENGLISH));
|
||||
assertEquals(expectedGroup.toLowerCase(Locale.ENGLISH),
|
||||
args[3].toLowerCase(Locale.ENGLISH));
|
||||
assertEquals(expectedUser.toLowerCase(), args[2].toLowerCase());
|
||||
assertEquals(expectedGroup.toLowerCase(), args[3].toLowerCase());
|
||||
}
|
||||
|
||||
@Test (timeout = 30000)
|
||||
|
@ -20,7 +20,6 @@
|
||||
import java.net.InetAddress;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.regex.Pattern;
|
||||
|
||||
import org.apache.commons.logging.Log;
|
||||
@ -360,10 +359,10 @@ private static Match getMatch(String line) {
|
||||
AccessPrivilege privilege = AccessPrivilege.READ_ONLY;
|
||||
switch (parts.length) {
|
||||
case 1:
|
||||
host = parts[0].toLowerCase(Locale.ENGLISH).trim();
|
||||
host = parts[0].toLowerCase().trim();
|
||||
break;
|
||||
case 2:
|
||||
host = parts[0].toLowerCase(Locale.ENGLISH).trim();
|
||||
host = parts[0].toLowerCase().trim();
|
||||
String option = parts[1].trim();
|
||||
if ("rw".equalsIgnoreCase(option)) {
|
||||
privilege = AccessPrivilege.READ_WRITE;
|
||||
|
@ -32,7 +32,6 @@
|
||||
import javax.servlet.http.HttpServletResponse;
|
||||
import java.io.IOException;
|
||||
import java.util.HashSet;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
|
||||
/**
|
||||
@ -83,8 +82,7 @@ public void doFilter(ServletRequest request, ServletResponse response,
|
||||
String method = httpReq.getMethod();
|
||||
if (method.equals("PUT") || method.equals("POST")) {
|
||||
String op = httpReq.getParameter(HttpFSFileSystem.OP_PARAM);
|
||||
if (op != null &&
|
||||
UPLOAD_OPERATIONS.contains(op.toUpperCase(Locale.ENGLISH))) {
|
||||
if (op != null && UPLOAD_OPERATIONS.contains(op.toUpperCase())) {
|
||||
if ("true".equalsIgnoreCase(httpReq.getParameter(HttpFSParametersProvider.DataParam.NAME))) {
|
||||
String contentType = httpReq.getContentType();
|
||||
contentTypeOK =
|
||||
|
@ -43,7 +43,6 @@
|
||||
import java.util.EnumSet;
|
||||
import java.util.LinkedHashMap;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.Map.Entry;
|
||||
|
||||
@ -569,8 +568,7 @@ public FSDelete(String path, boolean recursive) {
|
||||
@Override
|
||||
public JSONObject execute(FileSystem fs) throws IOException {
|
||||
boolean deleted = fs.delete(path, recursive);
|
||||
return toJSON(
|
||||
HttpFSFileSystem.DELETE_JSON.toLowerCase(Locale.ENGLISH), deleted);
|
||||
return toJSON(HttpFSFileSystem.DELETE_JSON.toLowerCase(), deleted);
|
||||
}
|
||||
|
||||
}
|
||||
|
@ -33,7 +33,6 @@
|
||||
|
||||
import javax.ws.rs.ext.Provider;
|
||||
import java.util.HashMap;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.regex.Pattern;
|
||||
|
||||
@ -169,8 +168,7 @@ public static class OperationParam extends EnumParam<HttpFSFileSystem.Operation>
|
||||
*/
|
||||
public OperationParam(String operation) {
|
||||
super(NAME, HttpFSFileSystem.Operation.class,
|
||||
HttpFSFileSystem.Operation.valueOf(
|
||||
operation.toUpperCase(Locale.ENGLISH)));
|
||||
HttpFSFileSystem.Operation.valueOf(operation.toUpperCase()));
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -36,7 +36,6 @@
|
||||
import java.util.Collections;
|
||||
import java.util.LinkedHashMap;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.Properties;
|
||||
|
||||
@ -203,7 +202,7 @@ public Server(String name, String homeDir, Configuration config) {
|
||||
* @param config server configuration.
|
||||
*/
|
||||
public Server(String name, String homeDir, String configDir, String logDir, String tempDir, Configuration config) {
|
||||
this.name = Check.notEmpty(name, "name").trim().toLowerCase(Locale.ENGLISH);
|
||||
this.name = Check.notEmpty(name, "name").trim().toLowerCase();
|
||||
this.homeDir = Check.notEmpty(homeDir, "homeDir");
|
||||
this.configDir = Check.notEmpty(configDir, "configDir");
|
||||
this.logDir = Check.notEmpty(logDir, "logDir");
|
||||
|
@ -43,7 +43,6 @@
|
||||
import java.security.PrivilegedExceptionAction;
|
||||
import java.util.Collection;
|
||||
import java.util.HashSet;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
@ -255,7 +254,7 @@ public void run() {
|
||||
private Set<String> toLowerCase(Collection<String> collection) {
|
||||
Set<String> set = new HashSet<String>();
|
||||
for (String value : collection) {
|
||||
set.add(value.toLowerCase(Locale.ENGLISH));
|
||||
set.add(value.toLowerCase());
|
||||
}
|
||||
return set;
|
||||
}
|
||||
@ -301,7 +300,7 @@ protected void closeFileSystem(FileSystem fs) throws IOException {
|
||||
|
||||
protected void validateNamenode(String namenode) throws FileSystemAccessException {
|
||||
if (nameNodeWhitelist.size() > 0 && !nameNodeWhitelist.contains("*")) {
|
||||
if (!nameNodeWhitelist.contains(namenode.toLowerCase(Locale.ENGLISH))) {
|
||||
if (!nameNodeWhitelist.contains(namenode.toLowerCase())) {
|
||||
throw new FileSystemAccessException(FileSystemAccessException.ERROR.H05, namenode, "not in whitelist");
|
||||
}
|
||||
}
|
||||
|
@ -22,7 +22,6 @@
|
||||
import org.apache.hadoop.util.StringUtils;
|
||||
|
||||
import java.util.Arrays;
|
||||
import java.util.Locale;
|
||||
|
||||
@InterfaceAudience.Private
|
||||
public abstract class EnumParam<E extends Enum<E>> extends Param<E> {
|
||||
@ -35,7 +34,7 @@ public EnumParam(String name, Class<E> e, E defaultValue) {
|
||||
|
||||
@Override
|
||||
protected E parse(String str) throws Exception {
|
||||
return Enum.valueOf(klass, str.toUpperCase(Locale.ENGLISH));
|
||||
return Enum.valueOf(klass, str.toUpperCase());
|
||||
}
|
||||
|
||||
@Override
|
||||
|
@ -20,7 +20,6 @@
|
||||
import java.util.Arrays;
|
||||
import java.util.EnumSet;
|
||||
import java.util.Iterator;
|
||||
import java.util.Locale;
|
||||
|
||||
import org.apache.hadoop.classification.InterfaceAudience;
|
||||
|
||||
@ -38,7 +37,7 @@ protected EnumSet<E> parse(String str) throws Exception {
|
||||
final EnumSet<E> set = EnumSet.noneOf(klass);
|
||||
if (!str.isEmpty()) {
|
||||
for (String sub : str.split(",")) {
|
||||
set.add(Enum.valueOf(klass, sub.trim().toUpperCase(Locale.ENGLISH)));
|
||||
set.add(Enum.valueOf(klass, sub.trim().toUpperCase()));
|
||||
}
|
||||
}
|
||||
return set;
|
||||
|
@ -33,7 +33,6 @@
|
||||
import java.text.MessageFormat;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
@ -71,7 +70,7 @@ public Parameters getValue(HttpContext httpContext) {
|
||||
}
|
||||
Enum op;
|
||||
try {
|
||||
op = Enum.valueOf(enumClass, str.toUpperCase(Locale.ENGLISH));
|
||||
op = Enum.valueOf(enumClass, str.toUpperCase());
|
||||
} catch (IllegalArgumentException ex) {
|
||||
throw new IllegalArgumentException(
|
||||
MessageFormat.format("Invalid Operation [{0}]", str));
|
||||
|
@ -18,7 +18,6 @@
|
||||
package org.apache.hadoop.hdfs;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
|
||||
import org.apache.hadoop.HadoopIllegalArgumentException;
|
||||
@ -58,22 +57,16 @@ public static XAttr buildXAttr(String name, byte[] value) {
|
||||
}
|
||||
|
||||
NameSpace ns;
|
||||
final String prefix = name.substring(0, prefixIndex)
|
||||
.toLowerCase(Locale.ENGLISH);
|
||||
if (prefix.equals(
|
||||
NameSpace.USER.toString().toLowerCase(Locale.ENGLISH))) {
|
||||
final String prefix = name.substring(0, prefixIndex).toLowerCase();
|
||||
if (prefix.equals(NameSpace.USER.toString().toLowerCase())) {
|
||||
ns = NameSpace.USER;
|
||||
} else if (prefix.equals(
|
||||
NameSpace.TRUSTED.toString().toLowerCase(Locale.ENGLISH))) {
|
||||
} else if (prefix.equals(NameSpace.TRUSTED.toString().toLowerCase())) {
|
||||
ns = NameSpace.TRUSTED;
|
||||
} else if (prefix.equals(
|
||||
NameSpace.SYSTEM.toString().toLowerCase(Locale.ENGLISH))) {
|
||||
} else if (prefix.equals(NameSpace.SYSTEM.toString().toLowerCase())) {
|
||||
ns = NameSpace.SYSTEM;
|
||||
} else if (prefix.equals(
|
||||
NameSpace.SECURITY.toString().toLowerCase(Locale.ENGLISH))) {
|
||||
} else if (prefix.equals(NameSpace.SECURITY.toString().toLowerCase())) {
|
||||
ns = NameSpace.SECURITY;
|
||||
} else if (prefix.equals(
|
||||
NameSpace.RAW.toString().toLowerCase(Locale.ENGLISH))) {
|
||||
} else if (prefix.equals(NameSpace.RAW.toString().toLowerCase())) {
|
||||
ns = NameSpace.RAW;
|
||||
} else {
|
||||
throw new HadoopIllegalArgumentException("An XAttr name must be " +
|
||||
@ -152,7 +145,7 @@ public static String getPrefixName(XAttr xAttr) {
|
||||
}
|
||||
|
||||
String namespace = xAttr.getNameSpace().toString();
|
||||
return namespace.toLowerCase(Locale.ENGLISH) + "." + xAttr.getName();
|
||||
return namespace.toLowerCase() + "." + xAttr.getName();
|
||||
}
|
||||
|
||||
/**
|
||||
|
@ -18,7 +18,6 @@
|
||||
package org.apache.hadoop.hdfs.protocol;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
|
||||
import org.apache.hadoop.classification.InterfaceAudience;
|
||||
@ -99,7 +98,7 @@ public static enum RollingUpgradeAction {
|
||||
|
||||
/** Covert the given String to a RollingUpgradeAction. */
|
||||
public static RollingUpgradeAction fromString(String s) {
|
||||
return MAP.get(s.toUpperCase(Locale.ENGLISH));
|
||||
return MAP.get(s.toUpperCase());
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -30,7 +30,6 @@
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
|
||||
/** A collection of block storage policies. */
|
||||
public class BlockStoragePolicySuite {
|
||||
@ -132,8 +131,7 @@ public BlockStoragePolicy[] getAllPolicies() {
|
||||
}
|
||||
|
||||
public static String buildXAttrName() {
|
||||
return XAttrNS.toString().toLowerCase(Locale.ENGLISH) + "."
|
||||
+ STORAGE_POLICY_XATTR_NAME;
|
||||
return XAttrNS.toString().toLowerCase() + "." + STORAGE_POLICY_XATTR_NAME;
|
||||
}
|
||||
|
||||
public static XAttr buildXAttr(byte policyId) {
|
||||
|
@ -20,7 +20,6 @@
|
||||
import java.io.DataInput;
|
||||
import java.io.DataOutput;
|
||||
import java.io.IOException;
|
||||
import java.util.Locale;
|
||||
import java.util.regex.Matcher;
|
||||
import java.util.regex.Pattern;
|
||||
|
||||
@ -54,7 +53,7 @@ public static enum RollingUpgradeStartupOption{
|
||||
|
||||
public String getOptionString() {
|
||||
return StartupOption.ROLLINGUPGRADE.getName() + " "
|
||||
+ name().toLowerCase(Locale.ENGLISH);
|
||||
+ name().toLowerCase();
|
||||
}
|
||||
|
||||
public boolean matches(StartupOption option) {
|
||||
@ -77,7 +76,7 @@ static RollingUpgradeStartupOption fromString(String s) {
|
||||
public static String getAllOptionString() {
|
||||
final StringBuilder b = new StringBuilder("<");
|
||||
for(RollingUpgradeStartupOption opt : VALUES) {
|
||||
b.append(opt.name().toLowerCase(Locale.ENGLISH)).append("|");
|
||||
b.append(opt.name().toLowerCase()).append("|");
|
||||
}
|
||||
b.setCharAt(b.length() - 1, '>');
|
||||
return b.toString();
|
||||
|
@ -18,7 +18,6 @@
|
||||
|
||||
package org.apache.hadoop.hdfs.server.datanode;
|
||||
|
||||
import java.util.Locale;
|
||||
import java.util.regex.Pattern;
|
||||
|
||||
import java.io.File;
|
||||
@ -89,8 +88,7 @@ public static StorageLocation parse(String rawLocation)
|
||||
String classString = matcher.group(1);
|
||||
location = matcher.group(2);
|
||||
if (!classString.isEmpty()) {
|
||||
storageType = StorageType.valueOf(
|
||||
classString.toUpperCase(Locale.ENGLISH));
|
||||
storageType = StorageType.valueOf(classString.toUpperCase());
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -75,7 +75,6 @@
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
import java.util.EnumMap;
|
||||
import java.util.Locale;
|
||||
import java.util.List;
|
||||
import java.util.zip.CheckedInputStream;
|
||||
import java.util.zip.Checksum;
|
||||
@ -4349,7 +4348,7 @@ static class RollingUpgradeOp extends FSEditLogOp { // @Idempotent
|
||||
|
||||
public RollingUpgradeOp(FSEditLogOpCodes code, String name) {
|
||||
super(code);
|
||||
this.name = name.toUpperCase(Locale.ENGLISH);
|
||||
this.name = name.toUpperCase();
|
||||
}
|
||||
|
||||
static RollingUpgradeOp getStartInstance(OpInstanceCache cache) {
|
||||
|
@ -18,8 +18,7 @@
|
||||
package org.apache.hadoop.hdfs.server.namenode;
|
||||
|
||||
import com.google.common.base.Objects;
|
||||
import org.apache.hadoop.fs.StorageType;
|
||||
import java.util.Locale;
|
||||
import org.apache.hadoop.hdfs.StorageType;
|
||||
|
||||
public class QuotaByStorageTypeEntry {
|
||||
private StorageType type;
|
||||
@ -54,7 +53,7 @@ public int hashCode() {
|
||||
public String toString() {
|
||||
StringBuilder sb = new StringBuilder();
|
||||
assert (type != null);
|
||||
sb.append(type.toString().toLowerCase(Locale.ENGLISH));
|
||||
sb.append(type.toString().toLowerCase());
|
||||
sb.append(':');
|
||||
sb.append(quota);
|
||||
return sb.toString();
|
||||
|
@ -587,7 +587,7 @@ private int processStartupCommand(CommandLineOpts opts) throws Exception {
|
||||
return 0;
|
||||
}
|
||||
|
||||
String cmd = opts.getCommand().toString().toLowerCase(Locale.ENGLISH);
|
||||
String cmd = opts.getCommand().toString().toLowerCase();
|
||||
|
||||
int exitCode = 0;
|
||||
try {
|
||||
|
@ -24,7 +24,6 @@
|
||||
import java.util.Arrays;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
|
||||
import org.apache.hadoop.HadoopIllegalArgumentException;
|
||||
@ -80,19 +79,19 @@ enum Command {
|
||||
private static final Map<String, CommandHandler> map;
|
||||
static {
|
||||
map = new HashMap<String, CommandHandler>();
|
||||
map.put(NAMENODE.getName().toLowerCase(Locale.ENGLISH),
|
||||
map.put(NAMENODE.getName().toLowerCase(),
|
||||
new NameNodesCommandHandler());
|
||||
map.put(SECONDARY.getName().toLowerCase(Locale.ENGLISH),
|
||||
map.put(SECONDARY.getName().toLowerCase(),
|
||||
new SecondaryNameNodesCommandHandler());
|
||||
map.put(BACKUP.getName().toLowerCase(Locale.ENGLISH),
|
||||
map.put(BACKUP.getName().toLowerCase(),
|
||||
new BackupNodesCommandHandler());
|
||||
map.put(INCLUDE_FILE.getName().toLowerCase(Locale.ENGLISH),
|
||||
map.put(INCLUDE_FILE.getName().toLowerCase(),
|
||||
new CommandHandler(DFSConfigKeys.DFS_HOSTS));
|
||||
map.put(EXCLUDE_FILE.getName().toLowerCase(Locale.ENGLISH),
|
||||
map.put(EXCLUDE_FILE.getName().toLowerCase(),
|
||||
new CommandHandler(DFSConfigKeys.DFS_HOSTS_EXCLUDE));
|
||||
map.put(NNRPCADDRESSES.getName().toLowerCase(Locale.ENGLISH),
|
||||
map.put(NNRPCADDRESSES.getName().toLowerCase(),
|
||||
new NNRpcAddressesCommandHandler());
|
||||
map.put(CONFKEY.getName().toLowerCase(Locale.ENGLISH),
|
||||
map.put(CONFKEY.getName().toLowerCase(),
|
||||
new PrintConfKeyCommandHandler());
|
||||
}
|
||||
|
||||
@ -117,7 +116,7 @@ public String getDescription() {
|
||||
}
|
||||
|
||||
public static CommandHandler getHandler(String cmd) {
|
||||
return map.get(cmd.toLowerCase(Locale.ENGLISH));
|
||||
return map.get(cmd.toLowerCase());
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -20,7 +20,6 @@
|
||||
import java.io.FileOutputStream;
|
||||
import java.io.IOException;
|
||||
import java.io.OutputStream;
|
||||
import java.util.Locale;
|
||||
|
||||
import org.apache.hadoop.classification.InterfaceAudience;
|
||||
import org.apache.hadoop.classification.InterfaceStability;
|
||||
@ -44,7 +43,7 @@ public class OfflineEditsVisitorFactory {
|
||||
*/
|
||||
static public OfflineEditsVisitor getEditsVisitor(String filename,
|
||||
String processor, boolean printToScreen) throws IOException {
|
||||
if(processor.toLowerCase(Locale.ENGLISH).equals("binary")) {
|
||||
if(processor.toLowerCase().equals("binary")) {
|
||||
return new BinaryEditsVisitor(filename);
|
||||
}
|
||||
OfflineEditsVisitor vis;
|
||||
@ -60,9 +59,9 @@ static public OfflineEditsVisitor getEditsVisitor(String filename,
|
||||
outs[1] = System.out;
|
||||
out = new TeeOutputStream(outs);
|
||||
}
|
||||
if(processor.toLowerCase(Locale.ENGLISH).equals("xml")) {
|
||||
if(processor.toLowerCase().equals("xml")) {
|
||||
vis = new XmlEditsVisitor(out);
|
||||
} else if(processor.toLowerCase(Locale.ENGLISH).equals("stats")) {
|
||||
} else if(processor.toLowerCase().equals("stats")) {
|
||||
vis = new StatisticsEditsVisitor(out);
|
||||
} else {
|
||||
throw new IOException("Unknown proccesor " + processor +
|
||||
|
@ -37,7 +37,6 @@
|
||||
import java.io.FileNotFoundException;
|
||||
import java.io.IOException;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
|
||||
import static io.netty.handler.codec.http.HttpHeaders.Names.CONNECTION;
|
||||
@ -142,7 +141,7 @@ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
|
||||
private static String getOp(QueryStringDecoder decoder) {
|
||||
Map<String, List<String>> parameters = decoder.parameters();
|
||||
return parameters.containsKey("op")
|
||||
? parameters.get("op").get(0).toUpperCase(Locale.ENGLISH) : null;
|
||||
? parameters.get("op").get(0).toUpperCase() : null;
|
||||
}
|
||||
|
||||
private static String getPath(QueryStringDecoder decoder)
|
||||
|
@ -23,7 +23,6 @@
|
||||
import java.util.HashMap;
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.Properties;
|
||||
|
||||
@ -97,7 +96,7 @@ private static HttpServletRequest toLowerCase(final HttpServletRequest request)
|
||||
|
||||
final Map<String, List<String>> m = new HashMap<String, List<String>>();
|
||||
for(Map.Entry<String, String[]> entry : original.entrySet()) {
|
||||
final String key = entry.getKey().toLowerCase(Locale.ENGLISH);
|
||||
final String key = entry.getKey().toLowerCase();
|
||||
List<String> strings = m.get(key);
|
||||
if (strings == null) {
|
||||
strings = new ArrayList<String>();
|
||||
|
@ -19,7 +19,6 @@
|
||||
|
||||
import java.net.URI;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
|
||||
import javax.ws.rs.core.MultivaluedMap;
|
||||
@ -76,7 +75,7 @@ private static URI rebuildQuery(final URI uri,
|
||||
final MultivaluedMap<String, String> parameters) {
|
||||
UriBuilder b = UriBuilder.fromUri(uri).replaceQuery("");
|
||||
for(Map.Entry<String, List<String>> e : parameters.entrySet()) {
|
||||
final String key = e.getKey().toLowerCase(Locale.ENGLISH);
|
||||
final String key = e.getKey().toLowerCase();
|
||||
for(String v : e.getValue()) {
|
||||
b = b.queryParam(key, v);
|
||||
}
|
||||
|
@ -32,7 +32,6 @@
|
||||
import java.util.ArrayList;
|
||||
import java.util.EnumSet;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.StringTokenizer;
|
||||
|
||||
@ -1243,7 +1242,7 @@ static URL removeOffsetParam(final URL url) throws MalformedURLException {
|
||||
if (query == null) {
|
||||
return url;
|
||||
}
|
||||
final String lower = query.toLowerCase(Locale.ENGLISH);
|
||||
final String lower = query.toLowerCase();
|
||||
if (!lower.startsWith(OFFSET_PARAM_PREFIX)
|
||||
&& !lower.contains("&" + OFFSET_PARAM_PREFIX)) {
|
||||
return url;
|
||||
@ -1254,7 +1253,7 @@ static URL removeOffsetParam(final URL url) throws MalformedURLException {
|
||||
for(final StringTokenizer st = new StringTokenizer(query, "&");
|
||||
st.hasMoreTokens();) {
|
||||
final String token = st.nextToken();
|
||||
if (!token.toLowerCase(Locale.ENGLISH).startsWith(OFFSET_PARAM_PREFIX)) {
|
||||
if (!token.toLowerCase().startsWith(OFFSET_PARAM_PREFIX)) {
|
||||
if (b == null) {
|
||||
b = new StringBuilder("?").append(token);
|
||||
} else {
|
||||
|
@ -18,7 +18,6 @@
|
||||
package org.apache.hadoop.hdfs.web.resources;
|
||||
|
||||
import java.util.Arrays;
|
||||
import java.util.Locale;
|
||||
|
||||
abstract class EnumParam<E extends Enum<E>> extends Param<E, EnumParam.Domain<E>> {
|
||||
EnumParam(final Domain<E> domain, final E value) {
|
||||
@ -41,7 +40,7 @@ public final String getDomain() {
|
||||
|
||||
@Override
|
||||
final E parse(final String str) {
|
||||
return Enum.valueOf(enumClass, str.toUpperCase(Locale.ENGLISH));
|
||||
return Enum.valueOf(enumClass, str.toUpperCase());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
@ -20,7 +20,6 @@
|
||||
import java.util.Arrays;
|
||||
import java.util.EnumSet;
|
||||
import java.util.Iterator;
|
||||
import java.util.Locale;
|
||||
|
||||
abstract class EnumSetParam<E extends Enum<E>> extends Param<EnumSet<E>, EnumSetParam.Domain<E>> {
|
||||
/** Convert an EnumSet to a string of comma separated values. */
|
||||
@ -83,8 +82,7 @@ final EnumSet<E> parse(final String str) {
|
||||
i = j > 0 ? j + 1 : 0;
|
||||
j = str.indexOf(',', i);
|
||||
final String sub = j >= 0? str.substring(i, j): str.substring(i);
|
||||
set.add(
|
||||
Enum.valueOf(enumClass, sub.trim().toUpperCase(Locale.ENGLISH)));
|
||||
set.add(Enum.valueOf(enumClass, sub.trim().toUpperCase()));
|
||||
}
|
||||
}
|
||||
return set;
|
||||
|
@ -25,7 +25,6 @@
|
||||
import static org.mockito.Mockito.spy;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Locale;
|
||||
|
||||
import org.apache.hadoop.hdfs.protocol.SnapshotException;
|
||||
import org.apache.hadoop.hdfs.server.namenode.FSDirectory;
|
||||
@ -71,7 +70,7 @@ public void testSnapshotLimits() throws Exception {
|
||||
Assert.fail("Expected SnapshotException not thrown");
|
||||
} catch (SnapshotException se) {
|
||||
Assert.assertTrue(
|
||||
se.getMessage().toLowerCase(Locale.ENGLISH).contains("rollover"));
|
||||
se.getMessage().toLowerCase().contains("rollover"));
|
||||
}
|
||||
|
||||
// Delete a snapshot to free up a slot.
|
||||
@ -87,7 +86,7 @@ public void testSnapshotLimits() throws Exception {
|
||||
Assert.fail("Expected SnapshotException not thrown");
|
||||
} catch (SnapshotException se) {
|
||||
Assert.assertTrue(
|
||||
se.getMessage().toLowerCase(Locale.ENGLISH).contains("rollover"));
|
||||
se.getMessage().toLowerCase().contains("rollover"));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
@ -23,7 +23,6 @@
|
||||
import java.util.EnumSet;
|
||||
import java.util.HashMap;
|
||||
import java.util.Iterator;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.Timer;
|
||||
import java.util.TimerTask;
|
||||
@ -712,8 +711,7 @@ public void processEventForJobSummary(HistoryEvent event, JobSummary summary,
|
||||
private void processEventForTimelineServer(HistoryEvent event, JobId jobId,
|
||||
long timestamp) {
|
||||
TimelineEvent tEvent = new TimelineEvent();
|
||||
tEvent.setEventType(
|
||||
event.getEventType().name().toUpperCase(Locale.ENGLISH));
|
||||
tEvent.setEventType(event.getEventType().name().toUpperCase());
|
||||
tEvent.setTimestamp(timestamp);
|
||||
TimelineEntity tEntity = new TimelineEntity();
|
||||
|
||||
|
@ -227,7 +227,7 @@ public void tasks() {
|
||||
try {
|
||||
String tt = $(TASK_TYPE);
|
||||
tt = tt.isEmpty() ? "All" : StringUtils.capitalize(MRApps.taskType(tt).
|
||||
toString().toLowerCase(Locale.ENGLISH));
|
||||
toString().toLowerCase(Locale.US));
|
||||
setTitle(join(tt, " Tasks for ", $(JOB_ID)));
|
||||
} catch (Exception e) {
|
||||
LOG.error("Failed to render tasks page with task type : "
|
||||
|
@ -21,7 +21,6 @@
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
|
||||
import org.apache.hadoop.conf.Configuration;
|
||||
import org.apache.hadoop.mapred.JobPriority;
|
||||
@ -315,7 +314,7 @@ public static org.apache.hadoop.mapreduce.QueueState fromYarn(
|
||||
QueueState state) {
|
||||
org.apache.hadoop.mapreduce.QueueState qState =
|
||||
org.apache.hadoop.mapreduce.QueueState.getState(
|
||||
state.toString().toLowerCase(Locale.ENGLISH));
|
||||
state.toString().toLowerCase());
|
||||
return qState;
|
||||
}
|
||||
|
||||
|
@ -30,7 +30,6 @@
|
||||
import java.util.Arrays;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
|
||||
import com.google.common.annotations.VisibleForTesting;
|
||||
@ -304,7 +303,7 @@ private static void addToClasspathIfNotJar(Path[] paths,
|
||||
remoteFS.getWorkingDirectory()));
|
||||
String name = (null == u.getFragment())
|
||||
? p.getName() : u.getFragment();
|
||||
if (!name.toLowerCase(Locale.ENGLISH).endsWith(".jar")) {
|
||||
if (!name.toLowerCase().endsWith(".jar")) {
|
||||
linkLookup.put(p, name);
|
||||
}
|
||||
}
|
||||
@ -318,7 +317,7 @@ private static void addToClasspathIfNotJar(Path[] paths,
|
||||
if (name == null) {
|
||||
name = p.getName();
|
||||
}
|
||||
if(!name.toLowerCase(Locale.ENGLISH).endsWith(".jar")) {
|
||||
if(!name.toLowerCase().endsWith(".jar")) {
|
||||
MRApps.addToEnvironment(
|
||||
environment,
|
||||
classpathEnvVar,
|
||||
|
@ -22,7 +22,6 @@
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
|
||||
import org.apache.hadoop.conf.Configuration;
|
||||
import org.apache.hadoop.mapreduce.JobStatus.State;
|
||||
@ -154,8 +153,7 @@ public void testFromYarnQueueInfo() {
|
||||
org.apache.hadoop.mapreduce.QueueInfo returned =
|
||||
TypeConverter.fromYarn(queueInfo, new Configuration());
|
||||
Assert.assertEquals("queueInfo translation didn't work.",
|
||||
returned.getState().toString(),
|
||||
queueInfo.getQueueState().toString().toLowerCase(Locale.ENGLISH));
|
||||
returned.getState().toString(), queueInfo.getQueueState().toString().toLowerCase());
|
||||
}
|
||||
|
||||
/**
|
||||
|
@ -28,7 +28,6 @@
|
||||
import java.util.HashMap;
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.NoSuchElementException;
|
||||
import java.util.concurrent.atomic.AtomicBoolean;
|
||||
@ -117,7 +116,7 @@ public static enum Counter {
|
||||
* BYTES_READ counter and second one is of the BYTES_WRITTEN counter.
|
||||
*/
|
||||
protected static String[] getFileSystemCounterNames(String uriScheme) {
|
||||
String scheme = uriScheme.toUpperCase(Locale.ENGLISH);
|
||||
String scheme = uriScheme.toUpperCase();
|
||||
return new String[]{scheme+"_BYTES_READ", scheme+"_BYTES_WRITTEN"};
|
||||
}
|
||||
|
||||
|
@ -227,7 +227,7 @@ else if (counters[ord] == null) {
|
||||
}
|
||||
|
||||
private String checkScheme(String scheme) {
|
||||
String fixed = scheme.toUpperCase(Locale.ENGLISH);
|
||||
String fixed = scheme.toUpperCase(Locale.US);
|
||||
String interned = schemes.putIfAbsent(fixed, fixed);
|
||||
if (schemes.size() > MAX_NUM_SCHEMES) {
|
||||
// mistakes or abuses
|
||||
|
@ -473,7 +473,7 @@ public static boolean checkURIs(URI[] uriFiles, URI[] uriArchives) {
|
||||
if (fragment == null) {
|
||||
return false;
|
||||
}
|
||||
String lowerCaseFragment = fragment.toLowerCase(Locale.ENGLISH);
|
||||
String lowerCaseFragment = fragment.toLowerCase();
|
||||
if (fragments.contains(lowerCaseFragment)) {
|
||||
return false;
|
||||
}
|
||||
@ -488,7 +488,7 @@ public static boolean checkURIs(URI[] uriFiles, URI[] uriArchives) {
|
||||
if (fragment == null) {
|
||||
return false;
|
||||
}
|
||||
String lowerCaseFragment = fragment.toLowerCase(Locale.ENGLISH);
|
||||
String lowerCaseFragment = fragment.toLowerCase();
|
||||
if (fragments.contains(lowerCaseFragment)) {
|
||||
return false;
|
||||
}
|
||||
|
@ -29,7 +29,6 @@
|
||||
import java.sql.Statement;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
||||
@ -163,8 +162,7 @@ public void setConf(Configuration conf) {
|
||||
this.connection = createConnection();
|
||||
|
||||
DatabaseMetaData dbMeta = connection.getMetaData();
|
||||
this.dbProductName =
|
||||
dbMeta.getDatabaseProductName().toUpperCase(Locale.ENGLISH);
|
||||
this.dbProductName = dbMeta.getDatabaseProductName().toUpperCase();
|
||||
}
|
||||
catch (Exception ex) {
|
||||
throw new RuntimeException(ex);
|
||||
|
@ -22,7 +22,6 @@
|
||||
import java.io.PrintWriter;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
import java.util.HashSet;
|
||||
import java.util.Arrays;
|
||||
@ -223,12 +222,12 @@ public int run(String[] argv) throws Exception {
|
||||
taskType = argv[2];
|
||||
taskState = argv[3];
|
||||
displayTasks = true;
|
||||
if (!taskTypes.contains(taskType.toUpperCase(Locale.ENGLISH))) {
|
||||
if (!taskTypes.contains(taskType.toUpperCase())) {
|
||||
System.out.println("Error: Invalid task-type: " + taskType);
|
||||
displayUsage(cmd);
|
||||
return exitCode;
|
||||
}
|
||||
if (!taskStates.contains(taskState.toLowerCase(Locale.ENGLISH))) {
|
||||
if (!taskStates.contains(taskState.toLowerCase())) {
|
||||
System.out.println("Error: Invalid task-state: " + taskState);
|
||||
displayUsage(cmd);
|
||||
return exitCode;
|
||||
@ -594,8 +593,7 @@ protected void displayTasks(Job job, String type, String state)
|
||||
throws IOException, InterruptedException {
|
||||
|
||||
TaskReport[] reports=null;
|
||||
reports = job.getTaskReports(
|
||||
TaskType.valueOf(type.toUpperCase(Locale.ENGLISH)));
|
||||
reports = job.getTaskReports(TaskType.valueOf(type.toUpperCase()));
|
||||
for (TaskReport report : reports) {
|
||||
TIPStatus status = report.getCurrentStatus();
|
||||
if ((state.equalsIgnoreCase("pending") && status ==TIPStatus.PENDING) ||
|
||||
|
@ -29,7 +29,6 @@
|
||||
import java.io.OutputStream;
|
||||
import java.io.PrintStream;
|
||||
import java.util.Date;
|
||||
import java.util.Locale;
|
||||
import java.util.Random;
|
||||
import java.util.StringTokenizer;
|
||||
import org.apache.commons.logging.Log;
|
||||
@ -155,16 +154,16 @@ long value() {
|
||||
static ByteMultiple parseString(String sMultiple) {
|
||||
if(sMultiple == null || sMultiple.isEmpty()) // MB by default
|
||||
return MB;
|
||||
String sMU = sMultiple.toUpperCase(Locale.ENGLISH);
|
||||
if(B.name().toUpperCase(Locale.ENGLISH).endsWith(sMU))
|
||||
String sMU = sMultiple.toUpperCase();
|
||||
if(B.name().toUpperCase().endsWith(sMU))
|
||||
return B;
|
||||
if(KB.name().toUpperCase(Locale.ENGLISH).endsWith(sMU))
|
||||
if(KB.name().toUpperCase().endsWith(sMU))
|
||||
return KB;
|
||||
if(MB.name().toUpperCase(Locale.ENGLISH).endsWith(sMU))
|
||||
if(MB.name().toUpperCase().endsWith(sMU))
|
||||
return MB;
|
||||
if(GB.name().toUpperCase(Locale.ENGLISH).endsWith(sMU))
|
||||
if(GB.name().toUpperCase().endsWith(sMU))
|
||||
return GB;
|
||||
if(TB.name().toUpperCase(Locale.ENGLISH).endsWith(sMU))
|
||||
if(TB.name().toUpperCase().endsWith(sMU))
|
||||
return TB;
|
||||
throw new IllegalArgumentException("Unsupported ByteMultiple "+sMultiple);
|
||||
}
|
||||
@ -737,7 +736,7 @@ public int run(String[] args) throws IOException {
|
||||
}
|
||||
|
||||
for (int i = 0; i < args.length; i++) { // parse command line
|
||||
if (args[i].toLowerCase(Locale.ENGLISH).startsWith("-read")) {
|
||||
if (args[i].toLowerCase().startsWith("-read")) {
|
||||
testType = TestType.TEST_TYPE_READ;
|
||||
} else if (args[i].equalsIgnoreCase("-write")) {
|
||||
testType = TestType.TEST_TYPE_WRITE;
|
||||
@ -756,10 +755,9 @@ public int run(String[] args) throws IOException {
|
||||
testType = TestType.TEST_TYPE_TRUNCATE;
|
||||
} else if (args[i].equalsIgnoreCase("-clean")) {
|
||||
testType = TestType.TEST_TYPE_CLEANUP;
|
||||
} else if (args[i].toLowerCase(Locale.ENGLISH).startsWith("-seq")) {
|
||||
} else if (args[i].toLowerCase().startsWith("-seq")) {
|
||||
isSequential = true;
|
||||
} else if (
|
||||
args[i].toLowerCase(Locale.ENGLISH).startsWith("-compression")) {
|
||||
} else if (args[i].toLowerCase().startsWith("-compression")) {
|
||||
compressionClass = args[++i];
|
||||
} else if (args[i].equalsIgnoreCase("-nrfiles")) {
|
||||
nrFiles = Integer.parseInt(args[++i]);
|
||||
|
@ -24,7 +24,6 @@
|
||||
import java.security.PrivilegedExceptionAction;
|
||||
import java.util.Arrays;
|
||||
import java.util.Collections;
|
||||
import java.util.Locale;
|
||||
import java.util.Random;
|
||||
import java.util.List;
|
||||
import java.util.ArrayList;
|
||||
@ -557,10 +556,7 @@ static void runTestCache(int port) throws Exception {
|
||||
static void checkPath(MiniDFSCluster cluster, FileSystem fileSys) throws IOException {
|
||||
InetSocketAddress add = cluster.getNameNode().getNameNodeAddress();
|
||||
// Test upper/lower case
|
||||
fileSys.checkPath(
|
||||
new Path("hdfs://"
|
||||
+ add.getHostName().toUpperCase(Locale.ENGLISH)
|
||||
+ ":" + add.getPort()));
|
||||
fileSys.checkPath(new Path("hdfs://" + add.getHostName().toUpperCase() + ":" + add.getPort()));
|
||||
}
|
||||
|
||||
public void testFsClose() throws Exception {
|
||||
|
@ -18,8 +18,6 @@
|
||||
|
||||
package org.apache.hadoop.fs.slive;
|
||||
|
||||
import java.util.Locale;
|
||||
|
||||
/**
|
||||
* Constants used in various places in slive
|
||||
*/
|
||||
@ -37,7 +35,7 @@ private Constants() {
|
||||
enum Distribution {
|
||||
BEG, END, UNIFORM, MID;
|
||||
String lowerName() {
|
||||
return this.name().toLowerCase(Locale.ENGLISH);
|
||||
return this.name().toLowerCase();
|
||||
}
|
||||
}
|
||||
|
||||
@ -47,7 +45,7 @@ String lowerName() {
|
||||
enum OperationType {
|
||||
READ, APPEND, RENAME, LS, MKDIR, DELETE, CREATE, TRUNCATE;
|
||||
String lowerName() {
|
||||
return this.name().toLowerCase(Locale.ENGLISH);
|
||||
return this.name().toLowerCase();
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -18,7 +18,6 @@
|
||||
|
||||
package org.apache.hadoop.fs.slive;
|
||||
|
||||
import java.util.Locale;
|
||||
import org.apache.hadoop.fs.slive.Constants.Distribution;
|
||||
|
||||
/**
|
||||
@ -53,8 +52,7 @@ class OperationData {
|
||||
percent = (Double.parseDouble(pieces[0]) / 100.0d);
|
||||
} else if (pieces.length >= 2) {
|
||||
percent = (Double.parseDouble(pieces[0]) / 100.0d);
|
||||
distribution =
|
||||
Distribution.valueOf(pieces[1].toUpperCase(Locale.ENGLISH));
|
||||
distribution = Distribution.valueOf(pieces[1].toUpperCase());
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -18,7 +18,6 @@
|
||||
|
||||
package org.apache.hadoop.fs.slive;
|
||||
|
||||
import java.util.Locale;
|
||||
import org.apache.hadoop.io.Text;
|
||||
|
||||
/**
|
||||
@ -68,8 +67,7 @@ static enum OutputType {
|
||||
"Invalid key format - no type seperator - " + TYPE_SEP);
|
||||
}
|
||||
try {
|
||||
dataType = OutputType.valueOf(
|
||||
key.substring(0, place).toUpperCase(Locale.ENGLISH));
|
||||
dataType = OutputType.valueOf(key.substring(0, place).toUpperCase());
|
||||
} catch (Exception e) {
|
||||
throw new IllegalArgumentException(
|
||||
"Invalid key format - invalid output type", e);
|
||||
|
@ -27,7 +27,6 @@
|
||||
import java.io.PrintWriter;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.TreeMap;
|
||||
|
||||
@ -158,7 +157,7 @@ private boolean getBool(String val) {
|
||||
if (val == null) {
|
||||
return false;
|
||||
}
|
||||
String cleanupOpt = val.toLowerCase(Locale.ENGLISH).trim();
|
||||
String cleanupOpt = val.toLowerCase().trim();
|
||||
if (cleanupOpt.equals("true") || cleanupOpt.equals("1")) {
|
||||
return true;
|
||||
} else {
|
||||
|
@ -23,7 +23,6 @@
|
||||
import java.util.Date;
|
||||
import java.util.EnumSet;
|
||||
import java.util.HashMap;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.Random;
|
||||
|
||||
@ -215,25 +214,23 @@ public int run(String[] argv) throws IOException {
|
||||
if (!(fmt == Format.txt || cod == CCodec.pln)) {
|
||||
for (CType typ : ct) {
|
||||
String fn =
|
||||
fmt.name().toUpperCase(Locale.ENGLISH) + "_" +
|
||||
cod.name().toUpperCase(Locale.ENGLISH) + "_" +
|
||||
typ.name().toUpperCase(Locale.ENGLISH);
|
||||
fmt.name().toUpperCase() + "_" +
|
||||
cod.name().toUpperCase() + "_" +
|
||||
typ.name().toUpperCase();
|
||||
typ.configure(job);
|
||||
System.out.print(
|
||||
rwop.name().toUpperCase(Locale.ENGLISH) + " " + fn + ": ");
|
||||
System.out.print(rwop.name().toUpperCase() + " " + fn + ": ");
|
||||
System.out.println(rwop.exec(fn, job) / 1000 +
|
||||
" seconds");
|
||||
}
|
||||
} else {
|
||||
String fn =
|
||||
fmt.name().toUpperCase(Locale.ENGLISH) + "_" +
|
||||
cod.name().toUpperCase(Locale.ENGLISH);
|
||||
fmt.name().toUpperCase() + "_" +
|
||||
cod.name().toUpperCase();
|
||||
Path p = new Path(root, fn);
|
||||
if (rwop == RW.r && !fs.exists(p)) {
|
||||
fn += cod.getExt();
|
||||
}
|
||||
System.out.print(
|
||||
rwop.name().toUpperCase(Locale.ENGLISH) + " " + fn + ": ");
|
||||
System.out.print(rwop.name().toUpperCase() + " " + fn + ": ");
|
||||
System.out.println(rwop.exec(fn, job) / 1000 +
|
||||
" seconds");
|
||||
}
|
||||
|
@ -28,7 +28,6 @@
|
||||
import java.util.EnumSet;
|
||||
import java.util.HashSet;
|
||||
import java.util.Iterator;
|
||||
import java.util.Locale;
|
||||
import java.util.Random;
|
||||
|
||||
import org.apache.hadoop.conf.Configuration;
|
||||
@ -281,7 +280,7 @@ public void configure(JobConf conf) {
|
||||
public void map(WritableComparable key, Text value,
|
||||
OutputCollector<Text, Text> output,
|
||||
Reporter reporter) throws IOException {
|
||||
String str = value.toString().toLowerCase(Locale.ENGLISH);
|
||||
String str = value.toString().toLowerCase();
|
||||
output.collect(new Text(str), value);
|
||||
}
|
||||
|
||||
|
@ -27,7 +27,6 @@
|
||||
import java.sql.ResultSet;
|
||||
import java.sql.SQLException;
|
||||
import java.sql.Statement;
|
||||
import java.util.Locale;
|
||||
import java.util.Random;
|
||||
|
||||
import org.apache.commons.logging.Log;
|
||||
@ -103,7 +102,7 @@ private void startHsqldbServer() {
|
||||
|
||||
private void createConnection(String driverClassName
|
||||
, String url) throws Exception {
|
||||
if(driverClassName.toLowerCase(Locale.ENGLISH).contains("oracle")) {
|
||||
if(driverClassName.toLowerCase().contains("oracle")) {
|
||||
isOracle = true;
|
||||
}
|
||||
Class.forName(driverClassName);
|
||||
|
@ -35,7 +35,6 @@
|
||||
import java.util.Comparator;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.TimeZone;
|
||||
|
||||
/**
|
||||
@ -330,8 +329,7 @@ public int compare(File lhs, File rhs) {
|
||||
}
|
||||
|
||||
private String normalizePath(File file) {
|
||||
return file.getPath().toUpperCase(Locale.ENGLISH)
|
||||
.replaceAll("\\\\", "/");
|
||||
return file.getPath().toUpperCase().replaceAll("\\\\", "/");
|
||||
}
|
||||
});
|
||||
byte[] md5 = computeMD5(files);
|
||||
|
@ -979,8 +979,8 @@ private static String trim(String s, String toTrim) {
|
||||
private String verifyAndConvertToStandardFormat(String rawDir) throws URISyntaxException {
|
||||
URI asUri = new URI(rawDir);
|
||||
if (asUri.getAuthority() == null
|
||||
|| asUri.getAuthority().toLowerCase(Locale.ENGLISH).equalsIgnoreCase(
|
||||
sessionUri.getAuthority().toLowerCase(Locale.ENGLISH))) {
|
||||
|| asUri.getAuthority().toLowerCase(Locale.US).equalsIgnoreCase(
|
||||
sessionUri.getAuthority().toLowerCase(Locale.US))) {
|
||||
// Applies to me.
|
||||
return trim(asUri.getPath(), "/");
|
||||
} else {
|
||||
|
@ -121,9 +121,8 @@ public static long getLong(Configuration configuration, String label) {
|
||||
*/
|
||||
public static Class<? extends InputFormat> getStrategy(Configuration conf,
|
||||
DistCpOptions options) {
|
||||
String confLabel = "distcp."
|
||||
+ options.getCopyStrategy().toLowerCase(Locale.ENGLISH)
|
||||
+ ".strategy.impl";
|
||||
String confLabel = "distcp." +
|
||||
options.getCopyStrategy().toLowerCase(Locale.getDefault()) + ".strategy.impl";
|
||||
return conf.getClass(confLabel, UniformSizeInputFormat.class, InputFormat.class);
|
||||
}
|
||||
|
||||
@ -222,8 +221,7 @@ public static void preserve(FileSystem targetFS, Path path,
|
||||
|
||||
final boolean preserveXAttrs = attributes.contains(FileAttribute.XATTR);
|
||||
if (preserveXAttrs || preserveRawXattrs) {
|
||||
final String rawNS =
|
||||
XAttr.NameSpace.RAW.name().toLowerCase(Locale.ENGLISH);
|
||||
final String rawNS = XAttr.NameSpace.RAW.name().toLowerCase();
|
||||
Map<String, byte[]> srcXAttrs = srcFileStatus.getXAttrs();
|
||||
Map<String, byte[]> targetXAttrs = getXAttrs(targetFS, path);
|
||||
if (srcXAttrs != null && !srcXAttrs.equals(targetXAttrs)) {
|
||||
@ -323,8 +321,7 @@ public static CopyListingFileStatus toCopyListingFileStatus(
|
||||
copyListingFileStatus.setXAttrs(srcXAttrs);
|
||||
} else {
|
||||
Map<String, byte[]> trgXAttrs = Maps.newHashMap();
|
||||
final String rawNS =
|
||||
XAttr.NameSpace.RAW.name().toLowerCase(Locale.ENGLISH);
|
||||
final String rawNS = XAttr.NameSpace.RAW.name().toLowerCase();
|
||||
for (Map.Entry<String, byte[]> ent : srcXAttrs.entrySet()) {
|
||||
final String xattrName = ent.getKey();
|
||||
if (xattrName.startsWith(rawNS)) {
|
||||
|
@ -31,7 +31,6 @@
|
||||
import java.util.Iterator;
|
||||
import java.util.LinkedList;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Random;
|
||||
import java.util.Stack;
|
||||
import java.util.StringTokenizer;
|
||||
@ -170,9 +169,7 @@ static enum FileAttribute {
|
||||
|
||||
final char symbol;
|
||||
|
||||
private FileAttribute() {
|
||||
symbol = toString().toLowerCase(Locale.ENGLISH).charAt(0);
|
||||
}
|
||||
private FileAttribute() {symbol = toString().toLowerCase().charAt(0);}
|
||||
|
||||
static EnumSet<FileAttribute> parse(String s) {
|
||||
if (s == null || s.length() == 0) {
|
||||
|
@ -24,7 +24,6 @@
|
||||
import org.apache.hadoop.mapred.gridmix.Statistics.ClusterStats;
|
||||
|
||||
import java.util.concurrent.CountDownLatch;
|
||||
import java.util.Locale;
|
||||
import java.io.IOException;
|
||||
|
||||
enum GridmixJobSubmissionPolicy {
|
||||
@ -85,6 +84,6 @@ public int getPollingInterval() {
|
||||
public static GridmixJobSubmissionPolicy getPolicy(
|
||||
Configuration conf, GridmixJobSubmissionPolicy defaultPolicy) {
|
||||
String policy = conf.get(JOB_SUBMISSION_POLICY, defaultPolicy.name());
|
||||
return valueOf(policy.toUpperCase(Locale.ENGLISH));
|
||||
return valueOf(policy.toUpperCase());
|
||||
}
|
||||
}
|
||||
|
@ -28,7 +28,6 @@
|
||||
import java.util.HashMap;
|
||||
import java.util.HashSet;
|
||||
import java.util.Iterator;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.StringTokenizer;
|
||||
import java.util.ArrayList;
|
||||
@ -320,43 +319,42 @@ private int initializeHadoopLogsAnalyzer(String[] args)
|
||||
}
|
||||
|
||||
for (int i = 0; i < args.length - (inputFilename == null ? 0 : 1); ++i) {
|
||||
if ("-h".equals(args[i].toLowerCase(Locale.ENGLISH))
|
||||
|| "-help".equals(args[i].toLowerCase(Locale.ENGLISH))) {
|
||||
if ("-h".equals(args[i].toLowerCase())
|
||||
|| "-help".equals(args[i].toLowerCase())) {
|
||||
usage();
|
||||
return 0;
|
||||
}
|
||||
|
||||
if ("-c".equals(args[i].toLowerCase(Locale.ENGLISH))
|
||||
|| "-collect-prefixes".equals(args[i].toLowerCase(Locale.ENGLISH))) {
|
||||
if ("-c".equals(args[i].toLowerCase())
|
||||
|| "-collect-prefixes".equals(args[i].toLowerCase())) {
|
||||
collecting = true;
|
||||
continue;
|
||||
}
|
||||
|
||||
// these control the job digest
|
||||
if ("-write-job-trace".equals(args[i].toLowerCase(Locale.ENGLISH))) {
|
||||
if ("-write-job-trace".equals(args[i].toLowerCase())) {
|
||||
++i;
|
||||
jobTraceFilename = new Path(args[i]);
|
||||
continue;
|
||||
}
|
||||
|
||||
if ("-single-line-job-traces".equals(
|
||||
args[i].toLowerCase(Locale.ENGLISH))) {
|
||||
if ("-single-line-job-traces".equals(args[i].toLowerCase())) {
|
||||
prettyprintTrace = false;
|
||||
continue;
|
||||
}
|
||||
|
||||
if ("-omit-task-details".equals(args[i].toLowerCase(Locale.ENGLISH))) {
|
||||
if ("-omit-task-details".equals(args[i].toLowerCase())) {
|
||||
omitTaskDetails = true;
|
||||
continue;
|
||||
}
|
||||
|
||||
if ("-write-topology".equals(args[i].toLowerCase(Locale.ENGLISH))) {
|
||||
if ("-write-topology".equals(args[i].toLowerCase())) {
|
||||
++i;
|
||||
topologyFilename = new Path(args[i]);
|
||||
continue;
|
||||
}
|
||||
|
||||
if ("-job-digest-spectra".equals(args[i].toLowerCase(Locale.ENGLISH))) {
|
||||
if ("-job-digest-spectra".equals(args[i].toLowerCase())) {
|
||||
ArrayList<Integer> values = new ArrayList<Integer>();
|
||||
|
||||
++i;
|
||||
@ -386,13 +384,13 @@ private int initializeHadoopLogsAnalyzer(String[] args)
|
||||
continue;
|
||||
}
|
||||
|
||||
if ("-d".equals(args[i].toLowerCase(Locale.ENGLISH))
|
||||
|| "-debug".equals(args[i].toLowerCase(Locale.ENGLISH))) {
|
||||
if ("-d".equals(args[i].toLowerCase())
|
||||
|| "-debug".equals(args[i].toLowerCase())) {
|
||||
debug = true;
|
||||
continue;
|
||||
}
|
||||
|
||||
if ("-spreads".equals(args[i].toLowerCase(Locale.ENGLISH))) {
|
||||
if ("-spreads".equals(args[i].toLowerCase())) {
|
||||
int min = Integer.parseInt(args[i + 1]);
|
||||
int max = Integer.parseInt(args[i + 2]);
|
||||
|
||||
@ -406,22 +404,22 @@ private int initializeHadoopLogsAnalyzer(String[] args)
|
||||
}
|
||||
|
||||
// These control log-wide CDF outputs
|
||||
if ("-delays".equals(args[i].toLowerCase(Locale.ENGLISH))) {
|
||||
if ("-delays".equals(args[i].toLowerCase())) {
|
||||
delays = true;
|
||||
continue;
|
||||
}
|
||||
|
||||
if ("-runtimes".equals(args[i].toLowerCase(Locale.ENGLISH))) {
|
||||
if ("-runtimes".equals(args[i].toLowerCase())) {
|
||||
runtimes = true;
|
||||
continue;
|
||||
}
|
||||
|
||||
if ("-tasktimes".equals(args[i].toLowerCase(Locale.ENGLISH))) {
|
||||
if ("-tasktimes".equals(args[i].toLowerCase())) {
|
||||
collectTaskTimes = true;
|
||||
continue;
|
||||
}
|
||||
|
||||
if ("-v1".equals(args[i].toLowerCase(Locale.ENGLISH))) {
|
||||
if ("-v1".equals(args[i].toLowerCase())) {
|
||||
version = 1;
|
||||
continue;
|
||||
}
|
||||
|
@ -20,7 +20,6 @@
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.Properties;
|
||||
import java.util.StringTokenizer;
|
||||
@ -434,7 +433,7 @@ private static Values getPre21Value(String name) {
|
||||
return Values.SUCCESS;
|
||||
}
|
||||
|
||||
return Values.valueOf(name.toUpperCase(Locale.ENGLISH));
|
||||
return Values.valueOf(name.toUpperCase());
|
||||
}
|
||||
|
||||
private void processTaskUpdatedEvent(TaskUpdatedEvent event) {
|
||||
|
@ -20,7 +20,6 @@
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
import java.util.TreeSet;
|
||||
|
||||
@ -244,7 +243,7 @@ public void incorporateCounters(JhCounters counters) {
|
||||
}
|
||||
|
||||
private static String canonicalizeCounterName(String nonCanonicalName) {
|
||||
String result = nonCanonicalName.toLowerCase(Locale.ENGLISH);
|
||||
String result = nonCanonicalName.toLowerCase();
|
||||
|
||||
result = result.replace(' ', '|');
|
||||
result = result.replace('-', '|');
|
||||
|
@ -20,7 +20,6 @@
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
import java.util.TreeSet;
|
||||
|
||||
@ -612,7 +611,7 @@ void setResourceUsageMetrics(ResourceUsageMetrics metrics) {
|
||||
}
|
||||
|
||||
private static String canonicalizeCounterName(String nonCanonicalName) {
|
||||
String result = nonCanonicalName.toLowerCase(Locale.ENGLISH);
|
||||
String result = nonCanonicalName.toLowerCase();
|
||||
|
||||
result = result.replace(' ', '|');
|
||||
result = result.replace('-', '|');
|
||||
|
@ -43,7 +43,7 @@ public Environment() throws IOException {
|
||||
// http://lopica.sourceforge.net/os.html
|
||||
String command = null;
|
||||
String OS = System.getProperty("os.name");
|
||||
String lowerOs = OS.toLowerCase(Locale.ENGLISH);
|
||||
String lowerOs = OS.toLowerCase();
|
||||
if (OS.indexOf("Windows") > -1) {
|
||||
command = "cmd /C set";
|
||||
} else if (lowerOs.indexOf("ix") > -1 || lowerOs.indexOf("linux") > -1
|
||||
|
@ -26,7 +26,6 @@
|
||||
import java.util.EnumSet;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
|
||||
import org.apache.commons.cli.CommandLine;
|
||||
@ -174,7 +173,7 @@ public int run(String[] args) throws Exception {
|
||||
if (types != null) {
|
||||
for (String type : types) {
|
||||
if (!type.trim().isEmpty()) {
|
||||
appTypes.add(type.toUpperCase(Locale.ENGLISH).trim());
|
||||
appTypes.add(type.toUpperCase().trim());
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -193,7 +192,7 @@ public int run(String[] args) throws Exception {
|
||||
}
|
||||
try {
|
||||
appStates.add(YarnApplicationState.valueOf(state
|
||||
.toUpperCase(Locale.ENGLISH).trim()));
|
||||
.toUpperCase().trim()));
|
||||
} catch (IllegalArgumentException ex) {
|
||||
sysout.println("The application state " + state
|
||||
+ " is invalid.");
|
||||
|
@ -27,7 +27,6 @@
|
||||
import java.util.Date;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
|
||||
import org.apache.commons.cli.CommandLine;
|
||||
@ -112,8 +111,7 @@ public int run(String[] args) throws Exception {
|
||||
if (types != null) {
|
||||
for (String type : types) {
|
||||
if (!type.trim().isEmpty()) {
|
||||
nodeStates.add(
|
||||
NodeState.valueOf(type.trim().toUpperCase(Locale.ENGLISH)));
|
||||
nodeStates.add(NodeState.valueOf(type.trim().toUpperCase()));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
@ -21,7 +21,6 @@
|
||||
import java.util.EnumSet;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
|
||||
import org.apache.commons.lang.math.LongRange;
|
||||
@ -214,7 +213,7 @@ public void setApplicationTags(Set<String> tags) {
|
||||
// Convert applicationTags to lower case and add
|
||||
this.applicationTags = new HashSet<String>();
|
||||
for (String tag : tags) {
|
||||
this.applicationTags.add(tag.toLowerCase(Locale.ENGLISH));
|
||||
this.applicationTags.add(tag.toLowerCase());
|
||||
}
|
||||
}
|
||||
|
||||
@ -259,8 +258,7 @@ public void setApplicationStates(EnumSet<YarnApplicationState> applicationStates
|
||||
public void setApplicationStates(Set<String> applicationStates) {
|
||||
EnumSet<YarnApplicationState> appStates = null;
|
||||
for (YarnApplicationState state : YarnApplicationState.values()) {
|
||||
if (applicationStates.contains(
|
||||
state.name().toLowerCase(Locale.ENGLISH))) {
|
||||
if (applicationStates.contains(state.name().toLowerCase())) {
|
||||
if (appStates == null) {
|
||||
appStates = EnumSet.of(state);
|
||||
} else {
|
||||
|
@ -19,7 +19,6 @@
|
||||
package org.apache.hadoop.yarn.api.records.impl.pb;
|
||||
|
||||
import java.util.HashSet;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
|
||||
import org.apache.hadoop.classification.InterfaceAudience.Private;
|
||||
@ -292,7 +291,7 @@ public void setApplicationTags(Set<String> tags) {
|
||||
// Convert applicationTags to lower case and add
|
||||
this.applicationTags = new HashSet<String>();
|
||||
for (String tag : tags) {
|
||||
this.applicationTags.add(tag.toLowerCase(Locale.ENGLISH));
|
||||
this.applicationTags.add(tag.toLowerCase());
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -241,8 +241,7 @@ void genFactoryMethod(String retName, String methodName, int indent) {
|
||||
puts(indent, "\n",
|
||||
"private <T extends _> ", retName, "<T> ", methodName,
|
||||
"_(T e, boolean inline) {\n",
|
||||
" return new ", retName, "<T>(\"",
|
||||
retName.toLowerCase(Locale.ENGLISH),
|
||||
" return new ", retName, "<T>(\"", retName.toLowerCase(Locale.US),
|
||||
"\", e, opt(", !endTagOptional.contains(retName), ", inline, ",
|
||||
retName.equals("PRE"), ")); }");
|
||||
}
|
||||
@ -259,7 +258,7 @@ void genNewElementMethod(String className, Method method, int indent) {
|
||||
puts(0, ") {");
|
||||
puts(indent,
|
||||
topMode ? "" : " closeAttrs();\n",
|
||||
" return ", retName.toLowerCase(Locale.ENGLISH), "_(this, ",
|
||||
" return ", retName.toLowerCase(Locale.US), "_(this, ",
|
||||
isInline(className, retName), ");\n", "}");
|
||||
} else if (params.length == 1) {
|
||||
puts(0, "String selector) {");
|
||||
|
@ -19,7 +19,6 @@
|
||||
package org.apache.hadoop.yarn.server.applicationhistoryservice.webapp;
|
||||
|
||||
import java.util.Collections;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
@ -148,8 +147,7 @@ public ContainerInfo getContainer(@Context HttpServletRequest req,
|
||||
}
|
||||
Set<String> appStates = parseQueries(statesQuery, true);
|
||||
for (String appState : appStates) {
|
||||
switch (YarnApplicationState.valueOf(
|
||||
appState.toUpperCase(Locale.ENGLISH))) {
|
||||
switch (YarnApplicationState.valueOf(appState.toUpperCase())) {
|
||||
case FINISHED:
|
||||
case FAILED:
|
||||
case KILLED:
|
||||
|
@ -24,7 +24,6 @@
|
||||
import java.util.EnumSet;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
import java.util.SortedSet;
|
||||
import java.util.TreeSet;
|
||||
@ -418,7 +417,7 @@ private static EnumSet<Field> parseFieldsStr(String str, String delimiter) {
|
||||
String[] strs = str.split(delimiter);
|
||||
List<Field> fieldList = new ArrayList<Field>();
|
||||
for (String s : strs) {
|
||||
s = s.trim().toUpperCase(Locale.ENGLISH);
|
||||
s = s.trim().toUpperCase();
|
||||
if (s.equals("EVENTS")) {
|
||||
fieldList.add(Field.EVENTS);
|
||||
} else if (s.equals("LASTEVENTONLY")) {
|
||||
|
@ -23,7 +23,6 @@
|
||||
import java.util.Arrays;
|
||||
import java.util.Collection;
|
||||
import java.util.HashSet;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
@ -165,7 +164,7 @@ public Collection<ApplicationReport> run() throws Exception {
|
||||
|
||||
if (checkAppStates
|
||||
&& !appStates.contains(appReport.getYarnApplicationState().toString()
|
||||
.toLowerCase(Locale.ENGLISH))) {
|
||||
.toLowerCase())) {
|
||||
continue;
|
||||
}
|
||||
if (finalStatusQuery != null && !finalStatusQuery.isEmpty()) {
|
||||
@ -187,7 +186,7 @@ public Collection<ApplicationReport> run() throws Exception {
|
||||
}
|
||||
if (checkAppTypes
|
||||
&& !appTypes.contains(appReport.getApplicationType().trim()
|
||||
.toLowerCase(Locale.ENGLISH))) {
|
||||
.toLowerCase())) {
|
||||
continue;
|
||||
}
|
||||
|
||||
@ -369,8 +368,7 @@ protected void init(HttpServletResponse response) {
|
||||
if (isState) {
|
||||
try {
|
||||
// enum string is in the uppercase
|
||||
YarnApplicationState.valueOf(
|
||||
paramStr.trim().toUpperCase(Locale.ENGLISH));
|
||||
YarnApplicationState.valueOf(paramStr.trim().toUpperCase());
|
||||
} catch (RuntimeException e) {
|
||||
YarnApplicationState[] stateArray =
|
||||
YarnApplicationState.values();
|
||||
@ -380,7 +378,7 @@ protected void init(HttpServletResponse response) {
|
||||
+ allAppStates);
|
||||
}
|
||||
}
|
||||
params.add(paramStr.trim().toLowerCase(Locale.ENGLISH));
|
||||
params.add(paramStr.trim().toLowerCase());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
@ -29,7 +29,6 @@
|
||||
import java.util.EnumSet;
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
@ -757,7 +756,7 @@ public void remove() {
|
||||
if (applicationTypes != null && !applicationTypes.isEmpty()) {
|
||||
String appTypeToMatch = caseSensitive
|
||||
? application.getApplicationType()
|
||||
: application.getApplicationType().toLowerCase(Locale.ENGLISH);
|
||||
: application.getApplicationType().toLowerCase();
|
||||
if (!applicationTypes.contains(appTypeToMatch)) {
|
||||
continue;
|
||||
}
|
||||
|
@ -18,7 +18,6 @@
|
||||
|
||||
package org.apache.hadoop.yarn.server.resourcemanager.resource;
|
||||
|
||||
import java.util.Locale;
|
||||
import org.apache.hadoop.classification.InterfaceAudience.Private;
|
||||
import org.apache.hadoop.classification.InterfaceStability.Evolving;
|
||||
|
||||
@ -62,7 +61,7 @@ public String toString() {
|
||||
sb.append(", ");
|
||||
}
|
||||
ResourceType resourceType = ResourceType.values()[i];
|
||||
sb.append(resourceType.name().toLowerCase(Locale.ENGLISH));
|
||||
sb.append(resourceType.name().toLowerCase());
|
||||
sb.append(String.format(" weight=%.1f", getWeight(resourceType)));
|
||||
}
|
||||
sb.append(">");
|
||||
|
@ -24,7 +24,6 @@
|
||||
import java.util.HashMap;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
import java.util.StringTokenizer;
|
||||
@ -395,8 +394,7 @@ public void setUserLimitFactor(String queue, float userLimitFactor) {
|
||||
public QueueState getState(String queue) {
|
||||
String state = get(getQueuePrefix(queue) + STATE);
|
||||
return (state != null) ?
|
||||
QueueState.valueOf(state.toUpperCase(Locale.ENGLISH)) :
|
||||
QueueState.RUNNING;
|
||||
QueueState.valueOf(state.toUpperCase()) : QueueState.RUNNING;
|
||||
}
|
||||
|
||||
public void setAccessibleNodeLabels(String queue, Set<String> labels) {
|
||||
@ -492,7 +490,7 @@ public boolean getReservationContinueLook() {
|
||||
}
|
||||
|
||||
private static String getAclKey(QueueACL acl) {
|
||||
return "acl_" + acl.toString().toLowerCase(Locale.ENGLISH);
|
||||
return "acl_" + acl.toString().toLowerCase();
|
||||
}
|
||||
|
||||
public AccessControlList getAcl(String queue, QueueACL acl) {
|
||||
|
@ -20,7 +20,6 @@
|
||||
import java.io.File;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.regex.Matcher;
|
||||
import java.util.regex.Pattern;
|
||||
|
||||
@ -242,7 +241,7 @@ public boolean getUsePortForNodeName() {
|
||||
public static Resource parseResourceConfigValue(String val)
|
||||
throws AllocationConfigurationException {
|
||||
try {
|
||||
val = val.toLowerCase(Locale.ENGLISH);
|
||||
val = val.toLowerCase();
|
||||
int memory = findResource(val, "mb");
|
||||
int vcores = findResource(val, "vcores");
|
||||
return BuilderUtils.newResource(memory, vcores);
|
||||
|
@ -17,7 +17,6 @@
|
||||
*/
|
||||
package org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair;
|
||||
|
||||
import java.util.Locale;
|
||||
import org.apache.hadoop.classification.InterfaceAudience.Public;
|
||||
import org.apache.hadoop.classification.InterfaceStability.Evolving;
|
||||
import org.apache.hadoop.util.ReflectionUtils;
|
||||
@ -73,7 +72,7 @@ public static SchedulingPolicy parse(String policy)
|
||||
throws AllocationConfigurationException {
|
||||
@SuppressWarnings("rawtypes")
|
||||
Class clazz;
|
||||
String text = policy.toLowerCase(Locale.ENGLISH);
|
||||
String text = policy.toLowerCase();
|
||||
if (text.equalsIgnoreCase(FairSharePolicy.NAME)) {
|
||||
clazz = FairSharePolicy.class;
|
||||
} else if (text.equalsIgnoreCase(FifoPolicy.NAME)) {
|
||||
|
@ -18,7 +18,6 @@
|
||||
|
||||
package org.apache.hadoop.yarn.server.resourcemanager.webapp;
|
||||
|
||||
import java.util.Locale;
|
||||
import static org.apache.hadoop.yarn.webapp.YarnWebParams.NODE_STATE;
|
||||
import static org.apache.hadoop.yarn.webapp.YarnWebParams.NODE_LABEL;
|
||||
import static org.apache.hadoop.yarn.webapp.view.JQueryUI.DATATABLES;
|
||||
@ -78,7 +77,7 @@ protected void render(Block html) {
|
||||
.th(".nodeManagerVersion", "Version")._()._().tbody();
|
||||
NodeState stateFilter = null;
|
||||
if (type != null && !type.isEmpty()) {
|
||||
stateFilter = NodeState.valueOf(type.toUpperCase(Locale.ENGLISH));
|
||||
stateFilter = NodeState.valueOf(type.toUpperCase());
|
||||
}
|
||||
Collection<RMNode> rmNodes = this.rm.getRMContext().getRMNodes().values();
|
||||
boolean isInactive = false;
|
||||
|
@ -30,7 +30,6 @@
|
||||
import java.util.HashMap;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import java.util.Locale;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
import java.util.concurrent.ConcurrentMap;
|
||||
@ -258,8 +257,7 @@ public NodesInfo getNodes(@QueryParam("states") String states) {
|
||||
} else {
|
||||
acceptedStates = EnumSet.noneOf(NodeState.class);
|
||||
for (String stateStr : states.split(",")) {
|
||||
acceptedStates.add(NodeState.valueOf(
|
||||
stateStr.toUpperCase(Locale.ENGLISH)));
|
||||
acceptedStates.add(NodeState.valueOf(stateStr.toUpperCase()));
|
||||
}
|
||||
}
|
||||
|
||||
@ -508,7 +506,7 @@ public ApplicationStatisticsInfo getAppStatistics(
|
||||
// if no states, returns the counts of all RMAppStates
|
||||
if (states.size() == 0) {
|
||||
for (YarnApplicationState state : YarnApplicationState.values()) {
|
||||
states.add(state.toString().toLowerCase(Locale.ENGLISH));
|
||||
states.add(state.toString().toLowerCase());
|
||||
}
|
||||
}
|
||||
// in case we extend to multiple applicationTypes in the future
|
||||
@ -520,9 +518,8 @@ public ApplicationStatisticsInfo getAppStatistics(
|
||||
ConcurrentMap<ApplicationId, RMApp> apps = rm.getRMContext().getRMApps();
|
||||
for (RMApp rmapp : apps.values()) {
|
||||
YarnApplicationState state = rmapp.createApplicationState();
|
||||
String type =
|
||||
rmapp.getApplicationType().trim().toLowerCase(Locale.ENGLISH);
|
||||
if (states.contains(state.toString().toLowerCase(Locale.ENGLISH))) {
|
||||
String type = rmapp.getApplicationType().trim().toLowerCase();
|
||||
if (states.contains(state.toString().toLowerCase())) {
|
||||
if (types.contains(ANY)) {
|
||||
countApp(scoreboard, state, ANY);
|
||||
} else if (types.contains(type)) {
|
||||
@ -557,8 +554,7 @@ private static Set<String> parseQueries(
|
||||
if (isState) {
|
||||
try {
|
||||
// enum string is in the uppercase
|
||||
YarnApplicationState.valueOf(
|
||||
paramStr.trim().toUpperCase(Locale.ENGLISH));
|
||||
YarnApplicationState.valueOf(paramStr.trim().toUpperCase());
|
||||
} catch (RuntimeException e) {
|
||||
YarnApplicationState[] stateArray =
|
||||
YarnApplicationState.values();
|
||||
@ -568,7 +564,7 @@ private static Set<String> parseQueries(
|
||||
+ " specified. It should be one of " + allAppStates);
|
||||
}
|
||||
}
|
||||
params.add(paramStr.trim().toLowerCase(Locale.ENGLISH));
|
||||
params.add(paramStr.trim().toLowerCase());
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -586,8 +582,7 @@ private static Map<YarnApplicationState, Map<String, Long>> buildScoreboard(
|
||||
for (String state : states) {
|
||||
Map<String, Long> partScoreboard = new HashMap<String, Long>();
|
||||
scoreboard.put(
|
||||
YarnApplicationState.valueOf(
|
||||
state.toUpperCase(Locale.ENGLISH)), partScoreboard);
|
||||
YarnApplicationState.valueOf(state.toUpperCase()), partScoreboard);
|
||||
// types is verified no to be empty
|
||||
for (String type : types) {
|
||||
partScoreboard.put(type, 0L);
|
||||
|
Loading…
Reference in New Issue
Block a user