From 07a0e18b8f03d783ce6ea4069eaa29e0d331c1c8 Mon Sep 17 00:00:00 2001 From: Jaromir Hamala Date: Fri, 5 Apr 2024 15:05:09 +0200 Subject: [PATCH] fix non-deterministic test --- integration-tests/debezium/src/test/java/kafka/DebeziumIT.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/integration-tests/debezium/src/test/java/kafka/DebeziumIT.java b/integration-tests/debezium/src/test/java/kafka/DebeziumIT.java index 21fcfa1..17ecb7c 100644 --- a/integration-tests/debezium/src/test/java/kafka/DebeziumIT.java +++ b/integration-tests/debezium/src/test/java/kafka/DebeziumIT.java @@ -168,7 +168,8 @@ public void testManyUpdates() throws Exception { + "2,\"IDB\",42.0\r\n" + "3,\"PDB\",42.0\r\n" + "4,\"KDB\",42.0\r\n", - "select id, symbol, last(price) as last_price from " + questTableName, + "select id, symbol, last(price) as last_price from " + questTableName + " order by id", + 120, questDBContainer.getMappedPort(QuestDBUtils.QUESTDB_HTTP_PORT)); // total number of rows is equal to the number of updates and inserts