HADOOP-8179. risk of NPE in CopyCommands processArguments() (Daryn Sharp via bobby)
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1309572 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
1b93f8e5c3
commit
fcacb14a1e
@ -386,6 +386,9 @@ Release 0.23.3 - UNRELEASED
|
|||||||
HADOOP-8088. User-group mapping cache incorrectly does negative caching on
|
HADOOP-8088. User-group mapping cache incorrectly does negative caching on
|
||||||
transient failures (Khiwal Lee via bobby)
|
transient failures (Khiwal Lee via bobby)
|
||||||
|
|
||||||
|
HADOOP-8179. risk of NPE in CopyCommands processArguments() (Daryn Sharp
|
||||||
|
via bobby)
|
||||||
|
|
||||||
Release 0.23.2 - UNRELEASED
|
Release 0.23.2 - UNRELEASED
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
@ -81,10 +81,9 @@ protected void processArguments(LinkedList<PathData> items)
|
|||||||
}
|
}
|
||||||
FSDataOutputStream out = dst.fs.create(dst.path);
|
FSDataOutputStream out = dst.fs.create(dst.path);
|
||||||
try {
|
try {
|
||||||
FSDataInputStream in = null;
|
|
||||||
for (PathData src : srcs) {
|
for (PathData src : srcs) {
|
||||||
|
FSDataInputStream in = src.fs.open(src.path);
|
||||||
try {
|
try {
|
||||||
in = src.fs.open(src.path);
|
|
||||||
IOUtils.copyBytes(in, out, getConf(), false);
|
IOUtils.copyBytes(in, out, getConf(), false);
|
||||||
if (delimiter != null) {
|
if (delimiter != null) {
|
||||||
out.write(delimiter.getBytes("UTF-8"));
|
out.write(delimiter.getBytes("UTF-8"));
|
||||||
|
Loading…
Reference in New Issue
Block a user