address pr feedback and revert ipv4 changes

Author: keshavdandeva

java-bigquery-jdbc/pom.xml

@@ -32,7 +32,6 @@
     <github.global.server>github</github.global.server>
     <site.installationModule>google-cloud-bigquery-jdbc</site.installationModule>
     <skipShade>false</skipShade>
-    <preferIpv4.test.argLine>-Djava.net.preferIPv4Stack=true</preferIpv4.test.argLine>
   </properties>
 
   <build>
@@ -48,7 +47,6 @@
         <artifactId>maven-surefire-plugin</artifactId>
         <version>3.5.2</version>
         <configuration>
-          <argLine>@{argLine} ${preferIpv4.test.argLine}</argLine>
           <skip>${skipSurefire}</skip>
           <systemPropertyVariables>
             <JDBC_TESTS>true</JDBC_TESTS>
@@ -59,7 +57,6 @@
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-failsafe-plugin</artifactId>
         <configuration>
-          <argLine>@{argLine} ${preferIpv4.test.argLine}</argLine>
           <systemPropertyVariables>
             <JDBC_TESTS>true</JDBC_TESTS>
           </systemPropertyVariables>
@@ -480,14 +477,14 @@
             <groupId>org.apache.maven.plugins</groupId>
             <artifactId>maven-surefire-plugin</artifactId>
             <configuration>
-              <argLine>@{argLine} ${preferIpv4.test.argLine} --add-opens=java.base/java.nio=org.apache.arrow.memory.core,ALL-UNNAMED</argLine>
+              <argLine>--add-opens=java.base/java.nio=org.apache.arrow.memory.core,ALL-UNNAMED</argLine>
             </configuration>
           </plugin>
           <plugin>
             <groupId>org.apache.maven.plugins</groupId>
             <artifactId>maven-failsafe-plugin</artifactId>
             <configuration>
-              <argLine>@{argLine} ${preferIpv4.test.argLine} --add-opens=java.base/java.nio=org.apache.arrow.memory.core,ALL-UNNAMED</argLine>
+              <argLine>--add-opens=java.base/java.nio=org.apache.arrow.memory.core,ALL-UNNAMED</argLine>
             </configuration>
           </plugin>
         </plugins>

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

@@ -30,6 +30,7 @@
 import io.opentelemetry.context.Context;
 import java.time.Instant;
 import java.util.Collections;
+import java.util.logging.ErrorManager;
 import java.util.logging.Handler;
 import java.util.logging.Level;
 import java.util.logging.LogRecord;
@@ -78,10 +79,8 @@ public void publish(LogRecord record) {
         publishToOTel(record, connectionId, config.openTelemetry);
       }
     } catch (Throwable t) {
-      reportError(
-          "Error publishing log to OpenTelemetry/GCP",
-          new Exception(t),
-          java.util.logging.ErrorManager.WRITE_FAILURE);
+      Exception ex = (t instanceof Exception) ? (Exception) t : new Exception(t);
+      reportError("Error publishing log to OpenTelemetry/GCP", ex, ErrorManager.WRITE_FAILURE);
     }
   }
 
@@ -185,10 +184,7 @@ public void flush() {
         try {
           config.loggingClient.flush();
         } catch (Exception e) {
-          reportError(
-              "Error flushing log to OpenTelemetry/GCP",
-              e,
-              java.util.logging.ErrorManager.FLUSH_FAILURE);
+          reportError("Error flushing log to OpenTelemetry/GCP", e, ErrorManager.FLUSH_FAILURE);
         }
       }
     }

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

@@ -36,6 +36,7 @@
 import com.google.cloud.bigquery.jdbc.BigQueryConnection;
 import com.google.cloud.bigquery.jdbc.BigQueryDriver;
 import com.google.cloud.bigquery.jdbc.DataSource;
+import com.google.cloud.bigquery.jdbc.OpenTelemetryJulHandler;
 import com.google.common.collect.ImmutableMap;
 import java.io.File;
 import java.io.IOException;
@@ -2808,8 +2809,7 @@ public void testPerConnectionLoggingE2E() throws SQLException, IOException {
       java.util.logging.Logger bqLogger =
           java.util.logging.Logger.getLogger("com.google.cloud.bigquery");
       for (java.util.logging.Handler h : bqLogger.getHandlers()) {
-        if (h instanceof java.util.logging.FileHandler
-            || h.getClass().getName().endsWith("PerConnectionFileHandler")) {
+        if (!(h instanceof OpenTelemetryJulHandler)) {
           h.close();
           bqLogger.removeHandler(h);
         }

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

@@ -307,7 +307,7 @@ private Trace verifyAndFetchTrace(String traceId) throws Exception {
 
   private <T> T pollWithRetry(java.util.concurrent.Callable<T> task) throws InterruptedException {
     int attempts = 0;
-    int maxAttempts = 24;
+    int maxAttempts = 10;
     long delayMs = 10000;
 
     // 10 second wait for GCP to ingest data