diff --git a/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/tool/LaunchMapper.java b/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/tool/LaunchMapper.java index 422e75e..a5ff67e 100644 --- a/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/tool/LaunchMapper.java +++ b/hcatalog/webhcat/svr/src/main/java/org/apache/hive/hcatalog/templeton/tool/LaunchMapper.java @@ -34,6 +34,7 @@ import org.apache.hadoop.security.UserGroupInformation; import org.apache.hadoop.util.Shell; import org.apache.hadoop.util.StringUtils; +import org.apache.hive.hcatalog.templeton.AppConfig; import org.apache.hive.hcatalog.templeton.BadParam; import org.apache.hive.hcatalog.templeton.LauncherDelegator; @@ -43,6 +44,7 @@ import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; +import java.io.OutputStreamWriter; import java.io.PrintWriter; import java.net.URISyntaxException; import java.util.ArrayList; @@ -544,9 +546,10 @@ public Watcher(Configuration conf, JobID jobid, InputStream in, String statusdir public void run() { PrintWriter writer = null; try { - InputStreamReader isr = new InputStreamReader(in); + String enc = conf.get(AppConfig.EXEC_ENCODING_NAME); + InputStreamReader isr = new InputStreamReader(in, enc); BufferedReader reader = new BufferedReader(isr); - writer = new PrintWriter(out); + writer = new PrintWriter(new OutputStreamWriter(out, enc)); String line; while ((line = reader.readLine()) != null) {