test: increase time out for migrations test (#7784)

confluentinc · Jul 13, 2021 · 1fd2ff1 · 1fd2ff1
1 parent 3c78e41
commit 1fd2ff1
Showing 1 changed file with 4 additions and 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
@@ -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
     );
   }
 }