Skip to content

Commit 07a0e18

Browse files
committed
fix non-deterministic test
1 parent 0f146cd commit 07a0e18

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

integration-tests/debezium/src/test/java/kafka/DebeziumIT.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,8 @@ public void testManyUpdates() throws Exception {
168168
+ "2,\"IDB\",42.0\r\n"
169169
+ "3,\"PDB\",42.0\r\n"
170170
+ "4,\"KDB\",42.0\r\n",
171-
"select id, symbol, last(price) as last_price from " + questTableName,
171+
"select id, symbol, last(price) as last_price from " + questTableName + " order by id",
172+
120,
172173
questDBContainer.getMappedPort(QuestDBUtils.QUESTDB_HTTP_PORT));
173174

174175
// total number of rows is equal to the number of updates and inserts

0 commit comments

Comments
 (0)