modified:   consumer/flume_node_watcher.go
	modified:   consumer/log_source.go
	modified:   consumer/log_source_manager.go
	modified:   main/flume-log.go