You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/01/10 19:19:49 UTC
[12/15] flink git commit: [tachyon] Minor fix in codestyle and
warnings
[tachyon] Minor fix in codestyle and warnings
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cebd628d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cebd628d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cebd628d
Branch: refs/heads/release-0.8
Commit: cebd628d5dc5815aa9f4119920b2fba84ed2e46c
Parents: d707dca
Author: Stephan Ewen <se...@apache.org>
Authored: Sat Jan 10 18:37:09 2015 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Sat Jan 10 18:42:21 2015 +0100
----------------------------------------------------------------------
.../src/test/java/org/apache/flink/tachyon/HDFSTest.java | 3 +--
.../org/apache/flink/tachyon/TachyonFileSystemWrapperTest.java | 3 +--
2 files changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/cebd628d/flink-addons/flink-tachyon/src/test/java/org/apache/flink/tachyon/HDFSTest.java
----------------------------------------------------------------------
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
index 9b4abd4..8d29ea7 100644
--- 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;
http://git-wip-us.apache.org/repos/asf/flink/blob/cebd628d/flink-addons/flink-tachyon/src/test/java/org/apache/flink/tachyon/TachyonFileSystemWrapperTest.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-tachyon/src/test/java/org/apache/flink/tachyon/TachyonFileSystemWrapperTest.java b/flink-addons/flink-tachyon/src/test/java/org/apache/flink/tachyon/TachyonFileSystemWrapperTest.java
index f425a49..e1235b6 100644
--- a/flink-addons/flink-tachyon/src/test/java/org/apache/flink/tachyon/TachyonFileSystemWrapperTest.java
+++ b/flink-addons/flink-tachyon/src/test/java/org/apache/flink/tachyon/TachyonFileSystemWrapperTest.java
@@ -25,7 +25,6 @@ import org.apache.flink.configuration.ConfigConstants;
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 class TachyonFileSystemWrapperTest {
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());