-
Notifications
You must be signed in to change notification settings - Fork 3.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Mention the path of DLQ to indicate DLQ if full for which pipeline #11280
Conversation
Since this is a community submitted pull request, a Jenkins build has not been kicked off automatically. Can an Elastic organization member please verify the contents of this patch and then kick off a build manually? |
@danhermann please provide feedback on the approach and implementation |
@@ -131,7 +131,7 @@ private void innerWriteEntry(DLQEntry entry) throws IOException { | |||
byte[] record = entry.serialize(); | |||
int eventPayloadSize = RECORD_HEADER_SIZE + record.length; | |||
if (currentQueueSize.longValue() + eventPayloadSize > maxQueueSize) { | |||
logger.error("cannot write event to DLQ: reached maxQueueSize of " + maxQueueSize); | |||
logger.error("cannot write event to DLQ(path:"+ this.queuePath +"): reached maxQueueSize of " + maxQueueSize); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@amitavmohanty01, this looks pretty good to me. There are a couple code formatting issues, but those are pretty minor. The line above should include spaces in the places where I inserted underscores below:
logger.error("cannot write event to DLQ_(path:_"_+ this.queuePath +_"): reached maxQueueSize of " + maxQueueSize);
I'll need to defer to someone on the @elastic/logstash team to approve and merge this PR, though.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I have modified as suggested and edited the commit.
c45178a
to
b9869ba
Compare
@amitavmohanty01 with PR #11075 there should already be the name of failing pipeline in the logs which cover point 1). |
@andsel thanks for the inputs. I am in agreement. Can you please trigger a Jenkins build so that we can be sure there is nothing missed out? |
Jenkins test this please |
@amitavmohanty01 The error should be resolved if you align the code to master (latest commits solved it):
|
b9869ba
to
76d6d66
Compare
@andsel I have rebased on master. Please trigger the Jenkins build again. |
@andsel ping |
Jenkins test this please |
@andsel it seems the errors on Jenkins are unrelated to my code. Am I missing something? |
@amitavmohanty01 to me seems all ok, I'll asking Jenkins to rebuild it. If it fails again probably there is a subtle dependency between the two facts to spoil |
Jenkins test this please |
@andsel I ran
Is the Jenkins environment having any nuances causing the failures? I am considering that especially because the failure and the code change seem unrelated. |
@amitavmohanty01 to build LogStash you have to execute |
@amitavmohanty01 with the integration of PR #11297 the issue is fixed. Please could you rebase your branch to the current master? |
76d6d66
to
0feb824
Compare
@andsel done |
Jenkins test this please |
2 similar comments
Jenkins test this please |
Jenkins test this please |
Adding a note here to not forget to backport on 7.5.0 once released so that it gets into 7.5.1 since we are late in the 7.5.0 release process. |
@andsel also, we should backport to 7.4 branch! |
Andrea Selva merged this into the following branches!
|
João Duarte merged this into the following branches!
|
A series of messages of the following form do not indicate DLQ for which pipeline is full.
[2019-10-30T11:53:33,801][ERROR][org.logstash.common.io.DeadLetterQueueWriter] cannot write event to DLQ: reached maxQueueSize of 1073741824
So, it is probably better to let the user know the path of the DLQ file so that the user can: