RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-22 18:47:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Hadoop: moveFromLocalFile uses copyFromLocalFile; is more robust.

Browse Source
This commit is contained in:
Greg Farnum 2009-07-29 19:27:02 -07:00
parent 9785824f8a
commit 546860e68c
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/client/hadoop/ceph/CephFileSystem.java
View File

@ -3,6 +3,7 @@ package org.apache.hadoop.fs.ceph;
import java.io.IOException;
import java.io.FileNotFoundException;
import java.io.File;
import java.io.OutputStream;
import java.net.URI;
import java.util.Set;
@ -578,11 +579,9 @@ public class CephFileSystem extends FileSystem {
@Override
public void moveFromLocalFile(Path src, Path dst) throws IOException {
debug("moveFromLocalFile:enter with src " + src + " and dest " + dst);
debug("calling ceph_moveFromLocalFile from java");
if (!ceph_copyFromLocalFile(src.toString(), dst.toString())) {
throw new IOException("org.apache.hadoop.fs.ceph.CephFileSystem.moveFromLocalFile: failed moving from local file " + src.toString() + " to Ceph file " + dst.toString());
}
debug("returned from ceph_moveFromLocalFile to java, success!");
copyFromLocalFile(src, dst);
File f = new File (src.toString());
if (!f.delete()) throw new IOException("Delete failed");
debug("moveFromLocalFile:exit");
}