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

Improve streaming ingestion completion timeout error message (#14636) 

* Improve streaming ingestion completion timeout error message

Co-authored-by: Kashif Faraz <kashif.faraz@gmail.com>
Co-authored-by: Benedict Jin <asdf2014@apache.org>
This commit is contained in:
AmatyaAvadhanula 2023-08-22 14:33:28 +05:30 committed by GitHub
parent 194a9c9abc
commit bd505062de
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java
View File

@ -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); log.warn("All tasks in group [%d] failed to publish, killing all tasks for these partitions", groupId);
} else { } else {
log.makeAlert( 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(), group.taskIds(),
groupId, groupId,
ioConfig.getCompletionTimeout() ioConfig.getCompletionTimeout()