added a log
This commit is contained in:
parent
81bef1295d
commit
1fc1a3d69a
|
@ -1,4 +0,0 @@
|
||||||
1) Usare un client hdfs per cancellare le stores
|
|
||||||
2) sostiuire il metodo expiredVersion s deleteVersions con un metodo solo che cancelli anche su hdfs
|
|
||||||
3) Non consentire operazioni lettura e scrittura sulle store in prepareDelete
|
|
||||||
|
|
|
@ -36,6 +36,7 @@ public class HdfsClient {
|
||||||
|
|
||||||
try (final FileSystem fs = FileSystem.get(conf)) {
|
try (final FileSystem fs = FileSystem.get(conf)) {
|
||||||
fs.delete(new Path(path), true);
|
fs.delete(new Path(path), true);
|
||||||
|
log.info("HDFS Pathe deleted: " + path);
|
||||||
} catch (IllegalArgumentException | IOException e) {
|
} catch (IllegalArgumentException | IOException e) {
|
||||||
log.error("Eror deleting path: " + path, e);
|
log.error("Eror deleting path: " + path, e);
|
||||||
throw new MDStoreManagerException("Eror deleting path: " + path, e);
|
throw new MDStoreManagerException("Eror deleting path: " + path, e);
|
||||||
|
|
Loading…
Reference in New Issue