Skip to content

Commit

Permalink
fix: return an error message on http2 /query-stream endpoint (#7750)
Browse files Browse the repository at this point in the history
* fix: added code to fail streams

* fix: add exception callback

* fix: remove error processor code

* fix: remove empty curl file

* fix: checkstyle violation

* chore: Trigger Build
  • Loading branch information
nateab authored Jul 6, 2021
1 parent 7438184 commit 3a4348b
Showing 1 changed file with 4 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -343,8 +343,10 @@ public BlockingRowQueue getQueue() {

@Override
public void onException(final Consumer<Throwable> onException) {
// We don't try to do anything on exception for push queries, but rely on the
// existing exception handling
queryMetadata.setUncaughtExceptionHandler(throwable -> {
onException.accept(throwable);
return null;
});
}

@Override
Expand Down

0 comments on commit 3a4348b

Please sign in to comment.