From ef0870ad038a1b72ea14ce550e34139b81eb901b Mon Sep 17 00:00:00 2001
From: Masatake Iwasaki <iwasakims@apache.org>
Date: Fri, 29 Apr 2016 20:25:52 +0900
Subject: [PATCH] HADOOP-12378. Fix findbugs warnings in hadoop-tools module.
 Contributed by Akira AJISAKA.

---
 .../java/org/apache/hadoop/ant/DfsTask.java   |  9 ++++--
 .../hadoop/ant/condition/DfsExists.java       |  2 +-
 .../apache/hadoop/ant/condition/DfsIsDir.java |  2 +-
 .../hadoop/ant/condition/DfsZeroLen.java      |  2 +-
 .../dev-support/findbugs-exclude.xml          | 29 +++++++++++++++++++
 hadoop-tools/hadoop-datajoin/pom.xml          | 11 +++++++
 6 files changed, 50 insertions(+), 5 deletions(-)
 create mode 100644 hadoop-tools/hadoop-datajoin/dev-support/findbugs-exclude.xml

diff --git a/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/DfsTask.java b/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/DfsTask.java
index 8dc7f3766eb..36119f5aac5 100644
--- a/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/DfsTask.java
+++ b/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/DfsTask.java
@@ -21,6 +21,7 @@ package org.apache.hadoop.ant;
 import java.io.ByteArrayOutputStream;
 import java.io.OutputStream;
 import java.io.PrintStream;
+import java.io.UnsupportedEncodingException;
 import java.security.AccessController;
 import java.security.PrivilegedAction;
 import java.util.LinkedList;
@@ -146,8 +147,12 @@ public class DfsTask extends Task {
   protected void pushContext() {
     antOut = System.out;
     antErr = System.err;
-    System.setOut(new PrintStream(out));
-    System.setErr(out == err ? System.out : new PrintStream(err));
+    try {
+      System.setOut(new PrintStream(out, false, "UTF-8"));
+      System.setErr(out == err ?
+          System.out : new PrintStream(err, false, "UTF-8"));
+    } catch (UnsupportedEncodingException ignored) {
+    }
   }
 
   /**
diff --git a/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/condition/DfsExists.java b/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/condition/DfsExists.java
index 8fbe872a836..95e38687956 100644
--- a/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/condition/DfsExists.java
+++ b/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/condition/DfsExists.java
@@ -19,6 +19,6 @@
 package org.apache.hadoop.ant.condition;
 
 public class DfsExists extends DfsBaseConditional {
-  protected final char flag = 'e';
+  protected static final char flag = 'e';
   protected char getFlag() { return flag; }
 }
diff --git a/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/condition/DfsIsDir.java b/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/condition/DfsIsDir.java
index e146d06dcf4..b889615896e 100644
--- a/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/condition/DfsIsDir.java
+++ b/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/condition/DfsIsDir.java
@@ -19,6 +19,6 @@
 package org.apache.hadoop.ant.condition;
 
 public class DfsIsDir extends DfsBaseConditional {
-  protected final char flag = 'd';
+  protected static final char flag = 'd';
   protected char getFlag() { return flag; }
 }
diff --git a/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/condition/DfsZeroLen.java b/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/condition/DfsZeroLen.java
index caac37847bb..70b4fbf2233 100644
--- a/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/condition/DfsZeroLen.java
+++ b/hadoop-tools/hadoop-ant/src/main/java/org/apache/hadoop/ant/condition/DfsZeroLen.java
@@ -19,6 +19,6 @@
 package org.apache.hadoop.ant.condition;
 
 public class DfsZeroLen extends DfsBaseConditional {
-  protected final char flag = 'z';
+  protected static final char flag = 'z';
   protected char getFlag() { return flag; }
 }
diff --git a/hadoop-tools/hadoop-datajoin/dev-support/findbugs-exclude.xml b/hadoop-tools/hadoop-datajoin/dev-support/findbugs-exclude.xml
new file mode 100644
index 00000000000..3544581dba5
--- /dev/null
+++ b/hadoop-tools/hadoop-datajoin/dev-support/findbugs-exclude.xml
@@ -0,0 +1,29 @@
+<!--
+   Licensed to the Apache Software Foundation (ASF) under one or more
+   contributor license agreements.  See the NOTICE file distributed with
+   this work for additional information regarding copyright ownership.
+   The ASF licenses this file to You under the Apache License, Version 2.0
+   (the "License"); you may not use this file except in compliance with
+   the License.  You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
+-->
+<FindBugsFilter>
+  <!-- These fields are useful for MapReduce jobs, so leave them as-is. -->
+  <Match>
+    <Class name="org.apache.hadoop.contrib.utils.join.DataJoinMapperBase" />
+    <Field name="inputTag" />
+    <Bug pattern="URF_UNREAD_PUBLIC_OR_PROTECTED_FIELD" />
+  </Match>
+  <Match>
+    <Class name="org.apache.hadoop.contrib.utils.join.DataJoinMapperBase" />
+    <Field name="job" />
+    <Bug pattern="URF_UNREAD_PUBLIC_OR_PROTECTED_FIELD" />
+  </Match>
+</FindBugsFilter>
diff --git a/hadoop-tools/hadoop-datajoin/pom.xml b/hadoop-tools/hadoop-datajoin/pom.xml
index 40445cb9ab0..03669b20d91 100644
--- a/hadoop-tools/hadoop-datajoin/pom.xml
+++ b/hadoop-tools/hadoop-datajoin/pom.xml
@@ -108,6 +108,17 @@
 
   <build>
     <plugins>
+      <plugin>
+        <groupId>org.codehaus.mojo</groupId>
+        <artifactId>findbugs-maven-plugin</artifactId>
+        <configuration>
+          <findbugsXmlOutput>true</findbugsXmlOutput>
+          <xmlOutput>true</xmlOutput>
+          <excludeFilterFile>${basedir}/dev-support/findbugs-exclude.xml
+          </excludeFilterFile>
+          <effort>Max</effort>
+        </configuration>
+      </plugin>
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-antrun-plugin</artifactId>