fix test error

Alluxio · Feb 23, 2017 · bafb553 · bafb553
1 parent 2ff9a8c
commit bafb553
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/tests/src/test/java/alluxio/shell/command/CheckConsistencyCommandTest.java b/tests/src/test/java/alluxio/shell/command/CheckConsistencyCommandTest.java
@@ -22,6 +22,7 @@
 import org.junit.Test;
 
 import java.io.InputStream;
+import java.io.OutputStream;
 
 public class CheckConsistencyCommandTest extends AbstractAlluxioShellTest {
   /**
@@ -73,10 +74,9 @@ public void inconsistent() throws Exception {
         WriteType.CACHE_THROUGH, 20);
     ufsPath = mFileSystem.getStatus(new AlluxioURI("/testRoot/testDir/testFileB")).getUfsPath();
     ufs.deleteFile(ufsPath);
-    ufs.create(ufsPath);
+    OutputStream outputStream = ufs.create(ufsPath);
-    InputStream inputStream = ufs.open(ufsPath);
     byte[] bytes = {1, 2, 3};
-    inputStream.read(bytes);
+    outputStream.write(bytes);
     mOutput.reset();
     mFsShell.run("checkConsistency", "-r", "/testRoot");
     res = mOutput.toString();