From 04f33043c83c6a542c7aa46b03dbd6fee9475321 Mon Sep 17 00:00:00 2001 From: Lucas Eby Date: Thu, 9 Oct 2025 17:22:07 -0500 Subject: [PATCH] [fix][test] Fixed nondeterministic ordering in MongoSourceTest.testWriteBadMessage --- .../org/apache/pulsar/io/mongodb/MongoSourceTest.java | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/pulsar-io/mongo/src/test/java/org/apache/pulsar/io/mongodb/MongoSourceTest.java b/pulsar-io/mongo/src/test/java/org/apache/pulsar/io/mongodb/MongoSourceTest.java index 7243b365e88a5..79b6fb4897301 100644 --- a/pulsar-io/mongo/src/test/java/org/apache/pulsar/io/mongodb/MongoSourceTest.java +++ b/pulsar-io/mongo/src/test/java/org/apache/pulsar/io/mongodb/MongoSourceTest.java @@ -128,9 +128,13 @@ public void testWriteBadMessage() throws Exception { Record record = source.read(); - assertEquals(new String(record.getValue()), - "{\"fullDocument\":{\"hello\":\"pulsar\"}," + String value = new String(record.getValue()); + String expected = "{\"fullDocument\":{\"hello\":\"pulsar\"}," + "\"ns\":{\"databaseName\":\"hello\",\"collectionName\":\"pulsar\",\"fullName\":\"hello.pulsar\"}," - + "\"operation\":\"INSERT\"}"); + + "\"operation\":\"INSERT\"}"; + assertEquals( + Document.parse(value), + Document.parse(expected) + ); } }