-
-
Notifications
You must be signed in to change notification settings - Fork 90
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
Forcefully emit batches on input timeout error #916
Conversation
d935836
to
d8d5731
Compare
d8d5731
to
7bb3866
Compare
ea42b26
to
af00012
Compare
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.
Looking good; the change request is for printing an error on parser failure, the other items are mostly discussion points.
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.
For the time being this is a reasonable workaround, I hope we'll be able to revert the changes to the source
in the future.
b7f8027
to
e69d3c1
Compare
e69d3c1
to
6578ed3
Compare
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.
Ideally we should have an integration test for this, but we need to add parallel execution capabilities to the testing tool first.
Note: This does not fix the underlying issue completely, but is a decent workaround that improves the latency between
source
andimporter
.