diff --git a/internal/benchrunner/runners/stream/runner.go b/internal/benchrunner/runners/stream/runner.go
index 490a68e777..563665ab70 100644
--- a/internal/benchrunner/runners/stream/runner.go
+++ b/internal/benchrunner/runners/stream/runner.go
@@ -206,12 +206,14 @@ func (r *runner) wipeDataStreamsOnSetup() error {
 func (r *runner) run() (err error) {
 	r.streamData()
 
+	ticker := time.NewTicker(1 * time.Second)
+	defer ticker.Stop()
 	for {
 		select {
 		case err = <-r.errChanGenerators:
 			close(r.done)
 			return err
-		default:
+		case <-ticker.C:
 			if signal.SIGINT() {
 				close(r.done)
 				return nil