DBZ-5434 Fix test failure

2022-08-01 14:36:09 -04:00 · 2022-08-01 14:36:09 -04:00 · 90a4c0059a
commit 90a4c0059a
parent 7c93c597f7
1 changed files with 2 additions and 0 deletions
--- a/debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/transforms/ExtractNewDocumentStateTestIT.java
+++ b/debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/transforms/ExtractNewDocumentStateTestIT.java
@ -1689,6 +1689,8 @@ public void testMatrixArrayAsDocumentType() throws InterruptedException, IOExcep
    @Test
    @FixFor("DBZ-5434")
    public void shouldSupportNestedArrays() throws InterruptedException {
+        waitForStreamingRunning();
+
        // Test insert
        primary().execute("insert", client -> {
            client.getDatabase(DB_NAME).getCollection(this.getCollectionName())