diff --git a/src/main/java/it/cnr/isti/epasmed/sistemainformativo/repository/SIMasterLogRepository.java b/src/main/java/it/cnr/isti/epasmed/sistemainformativo/repository/SIMasterLogRepository.java
index e43d931..c4f754d 100755
--- a/src/main/java/it/cnr/isti/epasmed/sistemainformativo/repository/SIMasterLogRepository.java
+++ b/src/main/java/it/cnr/isti/epasmed/sistemainformativo/repository/SIMasterLogRepository.java
@@ -42,8 +42,12 @@ public class SIMasterLogRepository {
 	public void closeFluxReads(String tabelleLette) throws Exception {
 		logger.info("Chiusura Flusso in lettura");
 		logger.info("Tabelle Lette: {}", tabelleLette);
-		if (tabelleLette.isEmpty()) {
+		if (tabelleLette == null) {
 			tabelleLette = " ";
+		} else {
+			if (tabelleLette.isEmpty()) {
+				tabelleLette = " ";
+			}
 		}
 
 		String query = "SELECT id_flusso FROM master_log"
@@ -67,18 +71,16 @@ public class SIMasterLogRepository {
 			logger.info("Flusso in lettura chiuso");
 		} else {
 			logger.error("Flusso da chiudere non trovato: {}", idsFlux);
-			throw new Exception("Errore chiudendo il flusso di lettura, id: "+idsFlux); 
-			
+			throw new Exception("Errore chiudendo il flusso di lettura, id: " + idsFlux);
+
 		}
 	}
 
 	public Long startFluxWrites() throws Exception {
 		logger.info("Iniziato Flusso in scrittura");
 		jdbcTemplate.update("INSERT INTO master_log (codice_flusso, tabelle, operazione, data_inizio_oper)"
-				+ " VALUES ('epas','epas_cartellini, epas_cartellini_rendicontazioni,"
-				+ " epas_orario,"
-				+ " epas_lavoro_fuori_sede, epas_aspettative, epas_pers_orario',"
-				+ " 'S',current_timestamp)");
+				+ " VALUES ('epas','epas_cartellini, epas_cartellini_rendicontazioni," + " epas_orario,"
+				+ " epas_lavoro_fuori_sede, epas_aspettative, epas_pers_orario'," + " 'S',current_timestamp)");
 		logger.info("Flusso in scrittura aperto");
 
 		String query = "SELECT id_flusso FROM master_log" + " WHERE codice_flusso='epas' AND operazione='S'"
@@ -96,18 +98,22 @@ public class SIMasterLogRepository {
 			fluxId = fluxIds.get(0);
 			logger.info("Flusso in scrittura id: {}", fluxId);
 		} else {
-			logger.error("Errore inizializando il flusso di scrittura, id: {}",fluxIds);
-			throw new Exception("Errore inizializando il flusso di scrittura, id: "+fluxIds); 
+			logger.error("Errore inizializando il flusso di scrittura, id: {}", fluxIds);
+			throw new Exception("Errore inizializando il flusso di scrittura, id: " + fluxIds);
 		}
-		
+
 		return fluxId;
 	}
 
 	public void closeFluxWrites(Long fluxId, String tabelleScritte) {
 		logger.info("Chiusura Flusso in scrittura");
 		logger.info("Tabelle Scritte: {}", tabelleScritte);
-		if (tabelleScritte.isEmpty()) {
+		if (tabelleScritte == null) {
 			tabelleScritte = " ";
+		} else {
+			if (tabelleScritte.isEmpty()) {
+				tabelleScritte = " ";
+			}
 		}
 
 		if (fluxId != null && fluxId.longValue() != 0) {