flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [12/15] flink git commit: [tachyon] Minor fix in codestyle and warnings
Date Sat, 10 Jan 2015 18:19:49 GMT
[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 <sewen@apache.org>
Authored: Sat Jan 10 18:37:09 2015 +0100
Committer: Stephan Ewen <sewen@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());


Mime
View raw message