ARROW-17199: [Java][FlightRPC] Clean up example Flight RPC server

apache · Jul 26, 2022 · b230b5b · b230b5b
1 parent a5a2837
commit b230b5b
Show file tree

Hide file tree

Showing 2 changed files with 52 additions and 544 deletions.
diff --git a/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlClient.java b/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlClient.java
@@ -38,7 +38,6 @@
 import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.nio.channels.Channels;
-import java.sql.SQLException;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.Iterator;
@@ -442,12 +441,8 @@ public PreparedStatement prepare(final String query, final CallOption... options
   }
 
   @Override
-  public void close() throws SQLException {
-    try {
-      AutoCloseables.close(client);
-    } catch (final Exception e) {
-      throw new SQLException(e);
-    }
+  public void close() throws Exception {
+    AutoCloseables.close(client);
   }
 
   /**
@@ -557,7 +552,7 @@ private Schema deserializeSchema(final ByteString bytes) {
      * @param options RPC-layer hints for this call.
      * @return a FlightInfo object representing the stream(s) to fetch.
      */
-    public FlightInfo execute(final CallOption... options) throws SQLException {
+    public FlightInfo execute(final CallOption... options) {
       checkOpen();
 
       final FlightDescriptor descriptor = FlightDescriptor