Skip to content

Commit

Permalink
Fixed the non deterministic test testSerdeWithSpecAndInputFormat
Browse files Browse the repository at this point in the history
  • Loading branch information
Yug Vajani committed Nov 21, 2024
1 parent bb44f85 commit f54f013
Showing 1 changed file with 17 additions and 11 deletions.
28 changes: 17 additions & 11 deletions ...ice/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorSpecTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -409,16 +409,22 @@ public void testSerdeWithSpecAndInputFormat() throws IOException
+ " \"spec\": {\n"
+ " \"dataSchema\": {\n"
+ " \"dataSource\": \"metrics-kafka\",\n"
+ " \"timestampSpec\": {\n"
+ " \"column\": \"timestamp\",\n"
+ " \"format\": \"auto\"\n"
+ " },\n"
+ " \"dimensionsSpec\": {\n"
+ " \"dimensions\": [],\n"
+ " \"dimensionExclusions\": [\n"
+ " \"timestamp\",\n"
+ " \"value\"\n"
+ " ]\n"
+ " \"parser\": {\n"
+ " \"type\": \"string\",\n"
+ " \"parseSpec\": {\n"
+ " \"format\": \"json\",\n"
+ " \"timestampSpec\": {\n"
+ " \"column\": \"timestamp\",\n"
+ " \"format\": \"auto\"\n"
+ " },\n"
+ " \"dimensionsSpec\": {\n"
+ " \"dimensions\": [],\n"
+ " \"dimensionExclusions\": [\n"
+ " \"timestamp\",\n"
+ " \"value\"\n"
+ " ]\n"
+ " }\n"
+ " }\n"
+ " },\n"
+ " \"metricsSpec\": [\n"
+ " {\n"
Expand Down Expand Up @@ -456,7 +462,7 @@ public void testSerdeWithSpecAndInputFormat() throws IOException
+ " \"fields\": []\n"
+ " },\n"
+ " \"featureSpec\": {}\n"
+ " },"
+ " },\n"
+ " \"consumerProperties\": {\n"
+ " \"bootstrap.servers\": \"localhost:9092\"\n"
+ " },\n"
Expand Down

0 comments on commit f54f013

Please sign in to comment.