import com.inin.analytics.elasticsearch.transport.SnapshotTransportStrategy;
public class IndexingPostProcessor {
private static transient Logger logger = LoggerFactory.getLogger(IndexingPostProcessor.class);
public void execute(Path jobOutput, Path manifestFile, String scratchDir, int numShardsPerIndex, Configuration conf, Class<? extends BaseESReducer> reducerClass) throws IOException, InstantiationException, IllegalAccessException {
FileSystem fs = FileSystem.get(conf);
<BUG>ESEmbededContainer esEmbededContainer = null;
try{</BUG>
Map<String, Integer> numShardsGenerated = new HashMap<String, Integer>();
FileUtil.copyMerge(fs, jobOutput, fs, manifestFile, false, conf, "");
BufferedReader br = new BufferedReader(new InputStreamReader(fs.open(manifestFile)));

import com.inin.analytics.elasticsearch.transport.SnapshotTransportStrategy;
public class IndexingPostProcessor {
private static transient Logger logger = LoggerFactory.getLogger(IndexingPostProcessor.class);
public void execute(Path jobOutput, Path manifestFile, String scratchDir, int numShardsPerIndex, Configuration conf, Class<? extends BaseESReducer> reducerClass) throws IOException, InstantiationException, IllegalAccessException {
FileSystem fs = FileSystem.get(conf);
ESEmbededContainer esEmbededContainer = null;
boolean rootManifestUploaded = false;
try{
Map<String, Integer> numShardsGenerated = new HashMap<String, Integer>();
FileUtil.copyMerge(fs, jobOutput, fs, manifestFile, false, conf, "");
BufferedReader br = new BufferedReader(new InputStreamReader(fs.open(manifestFile)));
