Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixed the non deterministic test testSerdeWithSpecAndInputFormat

This commit is contained in:
Yug Vajani 2024-11-21 10:43:51 -06:00
parent bb44f85bb6
commit f54f0134b2
1 changed files with 17 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorSpecTest.java
View File

@ -409,6 +409,10 @@ public class KafkaSupervisorSpecTest
+ " \"spec\": {\n" + " \"spec\": {\n"
+ " \"dataSchema\": {\n" + " \"dataSchema\": {\n"
+ " \"dataSource\": \"metrics-kafka\",\n" + " \"dataSource\": \"metrics-kafka\",\n"
+ " \"parser\": {\n"
+ " \"type\": \"string\",\n"
+ " \"parseSpec\": {\n"
+ " \"format\": \"json\",\n"
+ " \"timestampSpec\": {\n" + " \"timestampSpec\": {\n"
+ " \"column\": \"timestamp\",\n" + " \"column\": \"timestamp\",\n"
+ " \"format\": \"auto\"\n" + " \"format\": \"auto\"\n"
@ -419,6 +423,8 @@ public class KafkaSupervisorSpecTest
+ " \"timestamp\",\n" + " \"timestamp\",\n"
+ " \"value\"\n" + " \"value\"\n"
+ " ]\n" + " ]\n"
+ " }\n"
+ " }\n"
+ " },\n" + " },\n"
+ " \"metricsSpec\": [\n" + " \"metricsSpec\": [\n"
+ " {\n" + " {\n"
@ -456,7 +462,7 @@ public class KafkaSupervisorSpecTest
+ " \"fields\": []\n" + " \"fields\": []\n"
+ " },\n" + " },\n"
+ " \"featureSpec\": {}\n" + " \"featureSpec\": {}\n"
+ " }," + " },\n"
+ " \"consumerProperties\": {\n" + " \"consumerProperties\": {\n"
+ " \"bootstrap.servers\": \"localhost:9092\"\n" + " \"bootstrap.servers\": \"localhost:9092\"\n"
+ " },\n" + " },\n"