chore: clean up based on pr comments

Author: keshavdandeva

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

@@ -912,20 +912,11 @@ private void processArrowStream(
       enqueueError(arrowBatchWrapperBlockingQueue, e);
       Thread.currentThread().interrupt();
     } catch (Exception e) {
-      if (e.getCause() instanceof InterruptedException || Thread.currentThread().isInterrupted()) {
-        LOG.log(
-            Level.WARNING,
-            "\n" + Thread.currentThread().getName() + " Interrupted @ arrowStreamProcessor",
-            e);
-        enqueueError(arrowBatchWrapperBlockingQueue, e);
-        Thread.currentThread().interrupt();
-      } else {
-        LOG.log(
-            Level.WARNING,
-            "\n" + Thread.currentThread().getName() + " Error @ arrowStreamProcessor",
-            e);
-        enqueueError(arrowBatchWrapperBlockingQueue, e);
-      }
+      LOG.log(
+          Level.WARNING,
+          "\n" + Thread.currentThread().getName() + " Error @ arrowStreamProcessor",
+          e);
+      enqueueError(arrowBatchWrapperBlockingQueue, e);
     } finally { // logic needed for graceful shutdown
       enqueueEndOfStream(arrowBatchWrapperBlockingQueue);
     }
@@ -1683,20 +1674,11 @@ private void parseAndPopulateRpcData(
       }
 
     } catch (Exception ex) {
-      if (ex.getCause() instanceof InterruptedException || Thread.currentThread().isInterrupted()) {
-        LOG.log(
-            Level.WARNING,
-            "\n" + Thread.currentThread().getName() + " Interrupted @ populateBufferAsync",
-            ex);
-        enqueueBufferError(bigQueryFieldValueListWrapperBlockingQueue, ex);
-        Thread.currentThread().interrupt();
-      } else {
-        LOG.log(
-            Level.WARNING,
-            "\n" + Thread.currentThread().getName() + " Error @ populateBufferAsync",
-            ex);
-        enqueueBufferError(bigQueryFieldValueListWrapperBlockingQueue, ex);
-      }
+      LOG.log(
+          Level.WARNING,
+          "\n" + Thread.currentThread().getName() + " Error @ populateBufferAsync",
+          ex);
+      enqueueBufferError(bigQueryFieldValueListWrapperBlockingQueue, ex);
     } finally {
       enqueueBufferEndOfStream(bigQueryFieldValueListWrapperBlockingQueue);
     }

java-bigquery-jdbc/src/test/java/com/google/cloud/bigquery/jdbc/it/ITOpenTelemetryTest.java

@@ -74,9 +74,8 @@ public void testExecute_withOpenTelemetryGcpExporter() throws Exception {
       // pages)
       String paginationQuery = "SELECT * FROM UNNEST(GENERATE_ARRAY(1, 150)) AS id;";
       try (ResultSet paginatedRs = statement.executeQuery(paginationQuery)) {
-        int rowCount = 0;
-        while (paginatedRs.next() && rowCount < 150) {
-          rowCount++;
+        while (paginatedRs.next()) {
+          // Drain the result set to trigger pagination fetches
         }
       }
     }