@@ -115,25 +115,40 @@ public static Collection<Object[]> params() {
115
115
}
116
116
117
117
/**
118
- * Name of committer to set in fs config. If "" do not set one.
118
+ * Name of committer to set in filesystem config. If "" do not set one.
119
119
*/
120
120
private final String fsCommitterName ;
121
- private final String pathCommitterName ;
121
+
122
+ /**
123
+ * Name of committer to set in job config.
124
+ */
125
+ private final String jobCommitterName ;
122
126
123
127
/**
124
128
* Expected committer class.
125
129
* If null: an exception is expected
126
130
*/
127
131
private final Class <? extends AbstractS3ACommitter > committerClass ;
128
132
133
+ /**
134
+ * Description from parameters, simply for thread names to be more informative.
135
+ */
129
136
private final String description ;
130
137
131
- public ITestS3ACommitterFactory (final String fsCommitterName ,
132
- final String pathCommitterName ,
138
+ /**
139
+ * Create a parameterized instance.
140
+ * @param fsCommitterName committer to set in filesystem config
141
+ * @param jobCommitterName committer to set in job config
142
+ * @param committerClass expected committer class
143
+ * @param description debug text for thread names.
144
+ */
145
+ public ITestS3ACommitterFactory (
146
+ final String fsCommitterName ,
147
+ final String jobCommitterName ,
133
148
final Class <? extends AbstractS3ACommitter > committerClass ,
134
149
final String description ) {
135
150
this .fsCommitterName = fsCommitterName ;
136
- this .pathCommitterName = pathCommitterName ;
151
+ this .jobCommitterName = jobCommitterName ;
137
152
this .committerClass = committerClass ;
138
153
this .description = description ;
139
154
}
@@ -178,7 +193,7 @@ public void setup() throws Exception {
178
193
jobConf .set (FileOutputFormat .OUTDIR , outDir .toUri ().toString ());
179
194
jobConf .set (MRJobConfig .TASK_ATTEMPT_ID , attempt0 );
180
195
jobConf .setInt (MRJobConfig .APPLICATION_ATTEMPT_ID , 1 );
181
- maybeSetCommitterName (jobConf , pathCommitterName );
196
+ maybeSetCommitterName (jobConf , jobCommitterName );
182
197
tContext = new TaskAttemptContextImpl (jobConf , taskAttempt0 );
183
198
184
199
LOG .info ("Filesystem Committer='{}'; task='{}'" ,
0 commit comments