@@ -121,7 +121,7 @@ public class I2IDSSMPredict {
try {
hdfsService.deleteOnExit(outputPath);
} catch (Exception e) {
- log.error(e);
+ log.error("deleteOnExit error outputPath {}", outputPath, e);
}
processedRdd.coalesce(repartition).saveAsTextFile(outputPath, GzipCodec.class);
@@ -19,7 +19,7 @@ public class HDFSService implements Serializable {
fSystem = FileSystem.get(new Configuration());
+ log.error("HDFSService instance error", e);