Repository: sqoop Updated Branches: refs/heads/sqoop2 c4e1ff1ee -> 2a01ff2c8
SQOOP-2733: Sqoop2: Integration Tests: Clean up mapreduce directory for IncrementalReadTest (Abraham Fine via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/2a01ff2c Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/2a01ff2c Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/2a01ff2c Branch: refs/heads/sqoop2 Commit: 2a01ff2c839262d271399316ab7bb441830d239b Parents: c4e1ff1 Author: Jarek Jarcec Cecho <[email protected]> Authored: Thu Dec 10 11:49:57 2015 +0100 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Thu Dec 10 11:49:57 2015 +0100 ---------------------------------------------------------------------- .../connector/jdbc/generic/IncrementalReadTest.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/2a01ff2c/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/IncrementalReadTest.java ---------------------------------------------------------------------- diff --git a/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/IncrementalReadTest.java b/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/IncrementalReadTest.java index 131ad5e..f850768 100644 --- a/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/IncrementalReadTest.java +++ b/test/src/test/java/org/apache/sqoop/integration/connector/jdbc/generic/IncrementalReadTest.java @@ -18,6 +18,7 @@ package org.apache.sqoop.integration.connector.jdbc.generic; import com.google.common.collect.Iterables; +import org.apache.hadoop.fs.Path; import org.apache.sqoop.connector.hdfs.configuration.ToFormat; import org.apache.sqoop.model.MConfigList; import org.apache.sqoop.model.MJob; @@ -75,6 +76,11 @@ public class IncrementalReadTest extends ConnectorTestCase implements ITest { } } + @BeforeMethod + public void cleanUpHDFS() throws Exception { + hdfsClient.delete(new Path(getMapreduceDirectory()), true); + } + @Test public void testTable() throws Exception { createAndLoadTableUbuntuReleases();
