diff --git a/backend/services/sink/main.go b/backend/services/sink/main.go
index b1bdf8d25..5893e93e6 100644
--- a/backend/services/sink/main.go
+++ b/backend/services/sink/main.go
@@ -20,8 +20,13 @@ import (
 func main() {
 	log.SetFlags(log.LstdFlags | log.LUTC | log.Llongfile)
 
-	writer := NewWriter(env.Uint16("FS_ULIMIT"), env.String("FS_DIR"))
-  
+	FS_DIR := env.String("FS_DIR");
+	if _, err := os.Stat(FS_DIR); os.IsNotExist(err) {
+		log.Fatalf("%v doesn't exist. %v", FS_DIR, err)
+	}
+
+	writer := NewWriter(env.Uint16("FS_ULIMIT"), FS_DIR)
+
   count := 0
 
 	consumer := queue.NewMessageConsumer(