File tree Expand file tree Collapse file tree
java-bigquery-jdbc/src/main/java/com/google/cloud/bigquery/jdbc Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -912,8 +912,7 @@ private void processArrowStream(
912912 enqueueError (arrowBatchWrapperBlockingQueue , e );
913913 Thread .currentThread ().interrupt ();
914914 } catch (Exception e ) {
915- if (e .getCause () instanceof InterruptedException
916- || Thread .currentThread ().isInterrupted ()) {
915+ if (e .getCause () instanceof InterruptedException || Thread .currentThread ().isInterrupted ()) {
917916 LOG .log (
918917 Level .WARNING ,
919918 "\n " + Thread .currentThread ().getName () + " Interrupted @ arrowStreamProcessor" ,
@@ -1684,8 +1683,7 @@ private void parseAndPopulateRpcData(
16841683 }
16851684
16861685 } catch (Exception ex ) {
1687- if (ex .getCause () instanceof InterruptedException
1688- || Thread .currentThread ().isInterrupted ()) {
1686+ if (ex .getCause () instanceof InterruptedException || Thread .currentThread ().isInterrupted ()) {
16891687 LOG .log (
16901688 Level .WARNING ,
16911689 "\n " + Thread .currentThread ().getName () + " Interrupted @ populateBufferAsync" ,
You can’t perform that action at this time.
0 commit comments