From 276b95b7b375a5369156d7b12ba006423291eda6 Mon Sep 17 00:00:00 2001
From: "miriam.baglioni" <miriam.baglioni@isti.cnr.it>
Date: Thu, 30 Apr 2020 15:05:17 +0200
Subject: [PATCH] add create file instruction

---
 .../main/java/eu/dnetlib/dhp/blacklist/ReadBlacklistFromDB.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/dhp-workflows/dhp-blacklist/src/main/java/eu/dnetlib/dhp/blacklist/ReadBlacklistFromDB.java b/dhp-workflows/dhp-blacklist/src/main/java/eu/dnetlib/dhp/blacklist/ReadBlacklistFromDB.java
index 4f66d2f109..305b476b0c 100644
--- a/dhp-workflows/dhp-blacklist/src/main/java/eu/dnetlib/dhp/blacklist/ReadBlacklistFromDB.java
+++ b/dhp-workflows/dhp-blacklist/src/main/java/eu/dnetlib/dhp/blacklist/ReadBlacklistFromDB.java
@@ -119,6 +119,7 @@ public class ReadBlacklistFromDB implements Closeable {
 		this.conf.set("fs.defaultFS", hdfsNameNode);
 		FileSystem fileSystem = FileSystem.get(this.conf);
 		Path hdfsWritePath = new Path(hdfsPath);
+		fileSystem.create(hdfsWritePath);
 		FSDataOutputStream fsDataOutputStream = fileSystem.append(hdfsWritePath);
 		this.writer = new BufferedWriter(new OutputStreamWriter(fsDataOutputStream, StandardCharsets.UTF_8));
 	}