-
Notifications
You must be signed in to change notification settings - Fork 85
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
feat: provide sample code for row-level error handling #1863
feat: provide sample code for row-level error handling #1863
Conversation
Warning: This pull request is touching the following templated files:
|
18e97b8
to
4118376
Compare
// Retry the remaining valid rows. | ||
if (dataNew.length() > 0) { | ||
try { | ||
this.parent.append(new AppendContext(dataNew, 0)); |
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.
Is there a way to start another thread and do this append? Currently this append can block waiting for inflight limit...
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.
Done. Both retries and row-errors are now handled by calls to append() made from a separate thread.
samples/snippets/src/test/java/com/example/bigquerystorage/WriteToDefaultStreamIT.java
Outdated
Show resolved
Hide resolved
4118376
to
43798cb
Compare
43798cb
to
27d4b2a
Compare
No description provided.