This is an automated email from the ASF dual-hosted git repository.
asdf2014 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 c9be1cb4e84 Clean useless InterruptedException warn in ingestion task
log (#15519)
c9be1cb4e84 is described below
commit c9be1cb4e84f15724a3d881fccc80e3b2432c0d5
Author: sensor <[email protected]>
AuthorDate: Fri Dec 15 11:18:53 2023 +0800
Clean useless InterruptedException warn in ingestion task log (#15519)
* Clean useless InterruptedException warn in ingestion task log
* test coverage for the code change, manually close the scheduler thread to
trigger Interrupt signal
---------
Co-authored-by: Qiong Chen <[email protected]>
---
.../src/main/java/org/apache/druid/emitter/kafka/KafkaEmitter.java | 4 ++++
.../test/java/org/apache/druid/emitter/kafka/KafkaEmitterTest.java | 2 ++
2 files changed, 6 insertions(+)
diff --git
a/extensions-contrib/kafka-emitter/src/main/java/org/apache/druid/emitter/kafka/KafkaEmitter.java
b/extensions-contrib/kafka-emitter/src/main/java/org/apache/druid/emitter/kafka/KafkaEmitter.java
index 4a58464f730..c776e3f2f8b 100644
---
a/extensions-contrib/kafka-emitter/src/main/java/org/apache/druid/emitter/kafka/KafkaEmitter.java
+++
b/extensions-contrib/kafka-emitter/src/main/java/org/apache/druid/emitter/kafka/KafkaEmitter.java
@@ -181,6 +181,10 @@ public class KafkaEmitter implements Emitter
}
}
catch (Throwable e) {
+ if (e instanceof InterruptedException && e.getMessage() == null) {
+ log.info("Normal exit.");
+ return;
+ }
log.warn(e, "Exception while getting record from queue or producer send,
Events would not be emitted anymore.");
}
}
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 9e6846a5d8b..f39e8e82606 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
@@ -140,6 +140,8 @@ public class KafkaEmitterTest
}
countDownSentEvents.await();
+ kafkaEmitter.close();
+
Assert.assertEquals(0, kafkaEmitter.getMetricLostCount());
Assert.assertEquals(0, kafkaEmitter.getAlertLostCount());
Assert.assertEquals(0, kafkaEmitter.getSegmentMetadataLostCount());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
