fix: add exceptions throwing to not swallow errors

Author: keshavdandeva

google-cloud-bigquery-jdbc/src/main/java/com/google/cloud/bigquery/jdbc/BigQueryStatement.java

@@ -844,6 +844,12 @@ Thread populateArrowBufferedQueue(
                 if (e.getStatusCode().getCode()
                     == com.google.api.gax.rpc.StatusCode.Code.NOT_FOUND) {
                   LOG.warning("Read session expired or not found: %s", e.getMessage());
+                  try {
+                    arrowBatchWrapperBlockingQueue.put(
+                        BigQueryArrowBatchWrapper.ofError(new BigQueryJdbcRuntimeException(e)));
+                  } catch (InterruptedException ie) {
+                    Thread.currentThread().interrupt();
+                  }
                   break;
                 }
                 if (retryCount >= MAX_RETRY_COUNT) {
@@ -881,6 +887,17 @@ Thread populateArrowBufferedQueue(
               Thread.currentThread().interrupt();
             }
             Thread.currentThread().interrupt();
+          } catch (Exception e) {
+            LOG.log(
+                Level.WARNING,
+                "\n" + Thread.currentThread().getName() + " Error @ arrowStreamProcessor",
+                e);
+            try {
+              arrowBatchWrapperBlockingQueue.put(
+                  BigQueryArrowBatchWrapper.ofError(new BigQueryJdbcRuntimeException(e)));
+            } catch (InterruptedException ie) {
+              Thread.currentThread().interrupt();
+            }
           } finally { // logic needed for graceful shutdown
             // marking end of stream
             try {