Repository: sqoop Updated Branches: refs/heads/trunk 122d1c0b2 -> 3c1fb870e
SQOOP-3393: TestNetezzaExternalTableExportMapper hangs (Daniel Voros via Szabolcs Vasas) This closes #63 Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/3c1fb870 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/3c1fb870 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/3c1fb870 Branch: refs/heads/trunk Commit: 3c1fb870e20bf2d0316a7eb0aa524e437499ab05 Parents: 122d1c0 Author: Szabolcs Vasas <[email protected]> Authored: Mon Dec 3 11:53:21 2018 +0100 Committer: Szabolcs Vasas <[email protected]> Committed: Mon Dec 3 11:53:21 2018 +0100 ---------------------------------------------------------------------- .../db/netezza/TestNetezzaExternalTableExportMapper.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/3c1fb870/src/test/org/apache/sqoop/mapreduce/db/netezza/TestNetezzaExternalTableExportMapper.java ---------------------------------------------------------------------- diff --git a/src/test/org/apache/sqoop/mapreduce/db/netezza/TestNetezzaExternalTableExportMapper.java b/src/test/org/apache/sqoop/mapreduce/db/netezza/TestNetezzaExternalTableExportMapper.java index b93c646..0f2d53f 100644 --- a/src/test/org/apache/sqoop/mapreduce/db/netezza/TestNetezzaExternalTableExportMapper.java +++ b/src/test/org/apache/sqoop/mapreduce/db/netezza/TestNetezzaExternalTableExportMapper.java @@ -44,6 +44,7 @@ import java.io.IOException; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; +import java.util.UUID; import static org.hamcrest.CoreMatchers.equalTo; import static org.hamcrest.CoreMatchers.is; @@ -53,6 +54,7 @@ import static org.mockito.Matchers.anyString; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.when; +@Category(UnitTest.class) public class TestNetezzaExternalTableExportMapper { // chained rule, see #rules @@ -199,6 +201,7 @@ public class TestNetezzaExternalTableExportMapper { Mapper.Context context = mock(Mapper.Context.class); Configuration conf = new Configuration(); + conf.set("mapreduce.task.id", UUID.randomUUID().toString()); when(context.getConfiguration()).thenReturn(conf); TaskAttemptID taskAttemptID = new TaskAttemptID();
