diff --git a/operator/builtin/input/file/rotation_test.go b/operator/builtin/input/file/rotation_test.go
index 846d0d26..7f15e05b 100644
--- a/operator/builtin/input/file/rotation_test.go
+++ b/operator/builtin/input/file/rotation_test.go
@@ -259,7 +259,7 @@ func (rt rotationTest) run(tc rotationTest, copyTruncate, sequential bool) func(
 			select {
 			case e := <-logReceived:
 				received = append(received, e.Record.(string))
-			case <-time.After(200 * time.Millisecond):
+			case <-time.After(3 * time.Second):
 				break LOOP
 			}
 		}
diff --git a/operator/builtin/input/file/util_test.go b/operator/builtin/input/file/util_test.go
index a124f738..e126c9a9 100644
--- a/operator/builtin/input/file/util_test.go
+++ b/operator/builtin/input/file/util_test.go
@@ -143,7 +143,7 @@ LOOP:
 		select {
 		case e := <-c:
 			receivedMessages = append(receivedMessages, e.Record.(string))
-		case <-time.After(time.Second):
+		case <-time.After(3 * time.Second):
 			break LOOP
 		}
 	}
@@ -152,7 +152,7 @@ LOOP:
 }
 
 func expectNoMessages(t *testing.T, c chan *entry.Entry) {
-	expectNoMessagesUntil(t, c, 200*time.Millisecond)
+	expectNoMessagesUntil(t, c, 3*time.Second)
 }
 
 func expectNoMessagesUntil(t *testing.T, c chan *entry.Entry, d time.Duration) {