You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ja...@apache.org on 2015/12/10 11:50:36 UTC
sqoop git commit: SQOOP-2733: Sqoop2: Integration Tests: Clean up
mapreduce directory for IncrementalReadTest
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 <ja...@apache.org>
Authored: Thu Dec 10 11:49:57 2015 +0100
Committer: Jarek Jarcec Cecho <ja...@apache.org>
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();