public void initialize(MapReduceContext context) throws Exception {
Map<String, String> runtimeArgs = context.getRuntimeArguments();
ETLBatchConfig etlConfig = GSON.fromJson(runtimeArgs.get(Constants.CONFIG_KEY), ETLBatchConfig.class);
String sourcePluginId = runtimeArgs.get(Constants.Source.PLUGINID);
String sinkPluginId = runtimeArgs.get(Constants.Sink.PLUGINID);
<BUG>List<String> transformIds = GSON.fromJson(runtimeArgs.get(Constants.Transform.PLUGINIDS), STRING_LIST_TYPE);
List<ETLStage> stageList = etlConfig.getTransforms();
List<Transformation> pipeline = Lists.newArrayListWithCapacity(stageList.size() + 2);

List<StageMetrics> stageMetrics = Lists.newArrayListWithCapacity(stageList.size() + 2);</BUG>
transforms = Lists.newArrayListWithCapacity(stageList.size());

public void initialize(MapReduceContext context) throws Exception {
Map<String, String> runtimeArgs = context.getRuntimeArguments();
ETLBatchConfig etlConfig = GSON.fromJson(runtimeArgs.get(Constants.CONFIG_KEY), ETLBatchConfig.class);
String sourcePluginId = runtimeArgs.get(Constants.Source.PLUGINID);
String sinkPluginId = runtimeArgs.get(Constants.Sink.PLUGINID);
List<String> transformIds = GSON.fromJson(runtimeArgs.get(Constants.Transform.PLUGINIDS), STRING_LIST_TYPE);
StageMetrics stageMetrics;
List<ETLStage> stageList = etlConfig.getTransforms();
List<TransformDetail> pipeline = Lists.newArrayListWithCapacity(stageList.size() + 2);
transforms = Lists.newArrayListWithCapacity(stageList.size());
