github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-02 18:11:13 +08:00
Code Issues Projects Releases Wiki Activity

SQOOP-3393: TestNetezzaExternalTableExportMapper hangs

Browse Source 
(Daniel Voros via Szabolcs Vasas)

This closes #63
This commit is contained in:
Szabolcs Vasas 2018-12-03 11:53:21 +01:00
parent 122d1c0b27
commit 3c1fb870e2
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/test/org/apache/sqoop/mapreduce/db/netezza/TestNetezzaExternalTableExportMapper.java
View File

@ -44,6 +44,7 @@
import java.sql.Connection; import java.sql.Connection;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
import java.sql.SQLException; import java.sql.SQLException;
import java.util.UUID;
import static org.hamcrest.CoreMatchers.equalTo; import static org.hamcrest.CoreMatchers.equalTo;
import static org.hamcrest.CoreMatchers.is; import static org.hamcrest.CoreMatchers.is;
@ -53,6 +54,7 @@
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when; import static org.mockito.Mockito.when;
@Category(UnitTest.class)
public class TestNetezzaExternalTableExportMapper { public class TestNetezzaExternalTableExportMapper {
// chained rule, see #rules // chained rule, see #rules
@ -199,6 +201,7 @@ private Mapper.Context getContext() throws java.io.IOException, InterruptedExcep
Mapper.Context context = mock(Mapper.Context.class); Mapper.Context context = mock(Mapper.Context.class);
Configuration conf = new Configuration(); Configuration conf = new Configuration();
conf.set("mapreduce.task.id", UUID.randomUUID().toString());
when(context.getConfiguration()).thenReturn(conf); when(context.getConfiguration()).thenReturn(conf);
TaskAttemptID taskAttemptID = new TaskAttemptID(); TaskAttemptID taskAttemptID = new TaskAttemptID();