Skip to content

Commit c045897

Browse files
bypass the lookup of the OS username in hadoop
1 parent 11bb3c2 commit c045897

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/test/java/io/cdap/plugin/gcp/gcs/sink/TestDelegatingGCSOutputCommitter.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,7 @@
3838
import org.apache.hadoop.mapred.TaskAttemptID;
3939
import org.apache.hadoop.mapreduce.JobContext;
4040
import org.apache.hadoop.mapreduce.TaskAttemptContext;
41+
import org.apache.hadoop.security.UserGroupInformation;
4142
import org.junit.Assert;
4243
import org.junit.Test;
4344

@@ -80,6 +81,7 @@ public class TestDelegatingGCSOutputCommitter {
8081
private static final String pathSuffix = LocalDate.now().format(DateTimeFormatter.ISO_DATE);
8182

8283
public TestDelegatingGCSOutputCommitter() throws IOException {
84+
UserGroupInformation.setLoginUser(UserGroupInformation.createRemoteUser("runner"));
8385
}
8486

8587
private void writeOutput(TaskAttemptContext context, DelegatingGCSOutputCommitter committer) throws IOException,

0 commit comments

Comments
 (0)