[tachyon] Minor fix in codestyle and warnings

mbalassi · Jan 18, 2015 · cd6da11 · cd6da11
1 parent 543453d
commit cd6da11
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/flink-addons/flink-tachyon/src/test/java/org/apache/flink/tachyon/HDFSTest.java b/flink-addons/flink-tachyon/src/test/java/org/apache/flink/tachyon/HDFSTest.java
@@ -15,11 +15,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.flink.tachyon;
 
+package org.apache.flink.tachyon;
 
 import org.apache.commons.io.IOUtils;
-import org.apache.flink.core.fs.FSDataInputStream;
 import org.apache.flink.core.fs.FileSystem;
 import org.apache.flink.core.fs.Path;
 import org.apache.flink.examples.java.wordcount.WordCount;

diff --git a/...ns/flink-tachyon/src/test/java/org/apache/flink/tachyon/TachyonFileSystemWrapperTest.java b/...ns/flink-tachyon/src/test/java/org/apache/flink/tachyon/TachyonFileSystemWrapperTest.java
@@ -25,7 +25,6 @@
 import org.apache.flink.configuration.GlobalConfiguration;
 import org.apache.flink.examples.java.wordcount.WordCount;
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
 import org.junit.After;
 import org.junit.Assert;
@@ -114,7 +113,7 @@ public void testHadoopLoadability() {
  Configuration conf = new Configuration();
  conf.addResource(HADOOP_CONFIG_PATH);
  Assert.assertEquals("tachyon.hadoop.TFS", conf.get("fs.tachyon.impl", null));
- FileSystem hfs = tPath.getFileSystem(conf);
+ tPath.getFileSystem(conf);
  } catch(Exception e) {
  e.printStackTrace();
  Assert.fail("Test failed with exception: "+e.getMessage());