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 broken argument unpacker of ChunkMessagePackEventStreamer.each #4159

Merged

Conversation

daipom
Copy link
Contributor

@daipom daipom commented Apr 28, 2023

Which issue(s) this PR fixes:
None.

What this PR does / why we need it:
The argument unpacker of ChunkMessagePackEventStreamer.each seems to have been added in order to match the feature with EventStream at

However, that previous implementation at that point does not work as expected.
It has never caused any issues just because the argument was not used at all.

When unpacker is passed, the following will be executed.

unpacker.each($block)

This just iterates the internal buffer of the unpacker without reading io of the chunk.
Thus it seems to me that this doesn't work as expected.

Note: It could be implemented so that this argument is used, but given that it has not been used so far, there is little need for it.

Docs Changes:
Not needed since it is an internal fix.

Release Note:
Same as the title.

@github-actions
Copy link

This PR has been automatically marked as stale because it has been open 30 days with no activity. Remove stale label or comment or this PR will be closed in 7 days

@github-actions github-actions bot added the stale label May 29, 2023
@daipom daipom removed the stale label May 29, 2023
@ashie ashie self-requested a review July 7, 2023 00:55
lib/fluent/event.rb Outdated Show resolved Hide resolved
@daipom daipom force-pushed the fix-ChunkMessagePackEventStreamer-invalid-argument branch from 8e8f46b to 9e19bdd Compare July 10, 2023 22:49
@daipom
Copy link
Contributor Author

daipom commented Jul 10, 2023

Rebased to the latest master.

The argument `unpacker` of `ChunkMessagePackEventStreamer.each`
seems to have been added in order to match the feature with
`EventStream` at c6c6c03.

However, that previous implementation at that point does not
work as expected.
It has never causes any issues just because the argument was not
used at all.

It could be implemented so that this argument is used, but given
that it has not been used so far, there is little need for it.

Signed-off-by: Daijiro Fukuda <[email protected]>
@daipom daipom force-pushed the fix-ChunkMessagePackEventStreamer-invalid-argument branch from 9e19bdd to 5121054 Compare July 10, 2023 23:09
@daipom
Copy link
Contributor Author

daipom commented Jul 10, 2023

I'm concerned about the many failures of CI.
I'll check it.

@daipom
Copy link
Contributor Author

daipom commented Jul 10, 2023

I think the failures have nothing to do with this PR.
Rerunning...

@ashie ashie merged commit e120693 into fluent:master Jul 11, 2023
@ashie
Copy link
Member

ashie commented Jul 11, 2023

Thanks!

@daipom daipom deleted the fix-ChunkMessagePackEventStreamer-invalid-argument branch July 11, 2023 02:04
@daipom
Copy link
Contributor Author

daipom commented Jul 11, 2023

Thanks for your review!

@daipom daipom added this to the v1.16.2 milestone Oct 10, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants