bugfix: finally store seems to work

Author: pkit

src/core/org/apache/hadoop/fs/swift/SwiftFileSystem.java

@@ -131,14 +131,15 @@ private class SwiftFsOutputStream extends OutputStream {
 		private PipedInputStream fromPipe;
 		private SwiftProgress callback;
 		private long pos = 0;
+		private Thread thread;
 
 		public SwiftFsOutputStream(final ISwiftFilesClient client, final String container,
 				final String objName, int bufferSize, Progressable progress) throws IOException {
 			this.toPipe = new PipedOutputStream();
 			this.fromPipe = new PipedInputStream(toPipe, bufferSize);
 			this.callback = new SwiftProgress(progress);
 
-			new Thread() {
+			this.thread = new Thread() {
 				public void run(){
 					try {
 						client.storeStreamedObject(container, fromPipe, "binary/octet-stream", objName, new HashMap<String, String>());
@@ -147,17 +148,20 @@ public void run(){
 						e.printStackTrace();
 					} 
 				}
-			}.start();
-
+			};
+			thread.start();
 		}
 
 		@Override
 		public synchronized void close() {
 			try {
 				toPipe.flush();
 				toPipe.close();
+				thread.join();
 			} catch (IOException e) {
 				e.printStackTrace();
+			} catch (InterruptedException e) {
+				e.printStackTrace();
 			}
 		}