This is an automated email from the ASF dual-hosted git repository.
zachjsh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new c225c19f814 fix copy paste issue in earlier PR (#15890)
c225c19f814 is described below
commit c225c19f81473fdc4f9111b3bdbdbd57d14765c7
Author: Tom <[email protected]>
AuthorDate: Mon Feb 12 16:49:19 2024 -0800
fix copy paste issue in earlier PR (#15890)
---
.../org/apache/druid/emitter/kafka/KafkaEmitterTest.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git
a/extensions-contrib/kafka-emitter/src/test/java/org/apache/druid/emitter/kafka/KafkaEmitterTest.java
b/extensions-contrib/kafka-emitter/src/test/java/org/apache/druid/emitter/kafka/KafkaEmitterTest.java
index bb471729910..74a412a203e 100644
---
a/extensions-contrib/kafka-emitter/src/test/java/org/apache/druid/emitter/kafka/KafkaEmitterTest.java
+++
b/extensions-contrib/kafka-emitter/src/test/java/org/apache/druid/emitter/kafka/KafkaEmitterTest.java
@@ -162,7 +162,7 @@ public class KafkaEmitterTest
Assert.assertEquals(0, kafkaEmitter.getMetricLostCount());
Assert.assertEquals(0, kafkaEmitter.getAlertLostCount());
- Assert.assertEquals(0, kafkaEmitter.getSegmentMetadataLostCount());
+ Assert.assertEquals(0, kafkaEmitter.getRequestLostCount());
Assert.assertEquals(0, kafkaEmitter.getSegmentMetadataLostCount());
Assert.assertEquals(0, kafkaEmitter.getInvalidLostCount());
}
@@ -206,7 +206,7 @@ public class KafkaEmitterTest
Assert.assertEquals(0, kafkaEmitter.getMetricLostCount());
Assert.assertEquals(0, kafkaEmitter.getAlertLostCount());
- Assert.assertEquals(0, kafkaEmitter.getSegmentMetadataLostCount());
+ Assert.assertEquals(0, kafkaEmitter.getRequestLostCount());
Assert.assertEquals(0, kafkaEmitter.getSegmentMetadataLostCount());
Assert.assertEquals(0, kafkaEmitter.getInvalidLostCount());
@@ -249,7 +249,7 @@ public class KafkaEmitterTest
Assert.assertEquals(0, kafkaEmitter.getMetricLostCount());
Assert.assertEquals(0, kafkaEmitter.getAlertLostCount());
- Assert.assertEquals(0, kafkaEmitter.getSegmentMetadataLostCount());
+ Assert.assertEquals(0, kafkaEmitter.getRequestLostCount());
Assert.assertEquals(0, kafkaEmitter.getSegmentMetadataLostCount());
Assert.assertEquals(0, kafkaEmitter.getInvalidLostCount());
}
@@ -342,7 +342,7 @@ public class KafkaEmitterTest
Assert.assertEquals(0, kafkaEmitter.getMetricLostCount());
Assert.assertEquals(0, kafkaEmitter.getAlertLostCount());
- Assert.assertEquals(0, kafkaEmitter.getSegmentMetadataLostCount());
+ Assert.assertEquals(0, kafkaEmitter.getRequestLostCount());
Assert.assertEquals(0, kafkaEmitter.getSegmentMetadataLostCount());
Assert.assertEquals(0, kafkaEmitter.getInvalidLostCount());
}
@@ -385,7 +385,7 @@ public class KafkaEmitterTest
Assert.assertEquals(0, kafkaEmitter.getMetricLostCount());
Assert.assertEquals(0, kafkaEmitter.getAlertLostCount());
- Assert.assertEquals(0, kafkaEmitter.getSegmentMetadataLostCount());
+ Assert.assertEquals(0, kafkaEmitter.getRequestLostCount());
Assert.assertEquals(0, kafkaEmitter.getSegmentMetadataLostCount());
Assert.assertEquals(UNKNOWN_EVENTS.size(),
kafkaEmitter.getInvalidLostCount());
}
@@ -460,7 +460,7 @@ public class KafkaEmitterTest
Assert.assertEquals(bufferEventsDrop, kafkaEmitter.getMetricLostCount());
Assert.assertEquals(0, kafkaEmitter.getAlertLostCount());
- Assert.assertEquals(0, kafkaEmitter.getSegmentMetadataLostCount());
+ Assert.assertEquals(0, kafkaEmitter.getRequestLostCount());
Assert.assertEquals(0, kafkaEmitter.getSegmentMetadataLostCount());
Assert.assertEquals(0, kafkaEmitter.getInvalidLostCount());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
