From 1fd2ff1747c97165c1b8fd136a2e4a48055a2c73 Mon Sep 17 00:00:00 2001
From: Almog Gavra <almog@confluent.io>
Date: Tue, 13 Jul 2021 12:07:13 -0700
Subject: [PATCH] test: increase time out for migrations test (#7784)

---
 .../io/confluent/ksql/tools/migrations/MigrationsTest.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/ksqldb-tools/src/test/java/io/confluent/ksql/tools/migrations/MigrationsTest.java b/ksqldb-tools/src/test/java/io/confluent/ksql/tools/migrations/MigrationsTest.java
index 4feada6cb161..71883b30974d 100644
--- a/ksqldb-tools/src/test/java/io/confluent/ksql/tools/migrations/MigrationsTest.java
+++ b/ksqldb-tools/src/test/java/io/confluent/ksql/tools/migrations/MigrationsTest.java
@@ -631,6 +631,7 @@ private static void waitForMetadataTableReady() {
 
   private static List<StreamedRow> waitForNumRows(final String pullQuery, final int numRows) {
     return assertThatEventually(
+        "Query '" + pullQuery + "' never got " + numRows + " rows",
         () -> {
           try {
             return makeKsqlQuery(pullQuery);
@@ -644,7 +645,9 @@ private static List<StreamedRow> waitForNumRows(final String pullQuery, final in
             }
           }
         },
-        hasSize(numRows)
+        hasSize(numRows),
+        1,
+        TimeUnit.MINUTES
     );
   }
 }
\ No newline at end of file