This is an automated email from the ASF dual-hosted git repository.
amatya 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 bd505062de Improve streaming ingestion completion timeout error
message (#14636)
bd505062de is described below
commit bd505062de13e7b54999faf80a9c771e6a3f93a2
Author: AmatyaAvadhanula <[email protected]>
AuthorDate: Tue Aug 22 14:33:28 2023 +0530
Improve streaming ingestion completion timeout error message (#14636)
* Improve streaming ingestion completion timeout error message
Co-authored-by: Kashif Faraz <[email protected]>
Co-authored-by: Benedict Jin <[email protected]>
---
.../indexing/seekablestream/supervisor/SeekableStreamSupervisor.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java
b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java
index e58dcdabf1..72380436fa 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java
@@ -3431,7 +3431,9 @@ public abstract class
SeekableStreamSupervisor<PartitionIdType, SequenceOffsetTy
log.warn("All tasks in group [%d] failed to publish, killing all
tasks for these partitions", groupId);
} else {
log.makeAlert(
- "No task in [%s] for taskGroup [%d] succeeded before the
completion timeout elapsed [%s]!",
+ "No task in [%s] for taskGroup [%d] succeeded before the
completion timeout elapsed [%s]! "
+ + "Check metrics and logs to see if the creation, publish or
handoff"
+ + " of any segment is taking longer than usual.",
group.taskIds(),
groupId,
ioConfig.getCompletionTimeout()
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
