Skip to content
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

Fix async publisher sending empty events #2455

Merged
merged 1 commit into from
Sep 5, 2016

Conversation

ruflin
Copy link
Member

@ruflin ruflin commented Sep 5, 2016

No description provided.

@tsg tsg added needs_backport PR is waiting to be backported to other branches. and removed backport labels Sep 5, 2016
if event.HasData() {
tmpEvents = append(tmpEvents, event)
}
}
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

we need to copy here? the events array is store in eventsBatch for pushing acked events(batches) to registrar. Interestingly the syncPublisher does forward all events without filtering.

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

No need to copy. I was thinking that eventsBatch also needs the filtered list, but if it is for the registrar this is not the case.

I simplified the implementation. Please have a look again.

The sync publisher also does the filtering on line 114.

@urso urso merged commit 95df88a into elastic:master Sep 5, 2016
ruflin added a commit to ruflin/beats that referenced this pull request Sep 5, 2016
@ruflin ruflin deleted the async-publisher branch September 5, 2016 12:15
@tsg tsg removed the needs_backport PR is waiting to be backported to other branches. label Sep 22, 2016
leweafan pushed a commit to leweafan/beats that referenced this pull request Apr 28, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants