diff --git a/pilot/filebeat_piloter.go b/pilot/filebeat_piloter.go
old mode 100644
new mode 100755
index 4b8077cb..d14db44c
--- a/pilot/filebeat_piloter.go
+++ b/pilot/filebeat_piloter.go
@@ -266,6 +266,7 @@ func (p *FilebeatPiloter) Start() error {
 		// try to restart filebeat
 		log.Warningf("filebeat exited and try to restart")
 		filebeat = nil
+		p.watchDone <- true
 		p.Start()
 	}()