Fix Minor POM Issues to allow Maven build (apache#161)

* Fix minor POM Issues to allow Maven Build * Revert Flight SQL POM State * Remove unused imports Co-authored-by: Rafael Telles <[email protected]>
rafael-telles · Dec 6, 2021 · a059c15 · a059c15
1 parent 79e15b5
commit a059c15
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 11 deletions.
diff --git a/java/flight/flight-jdbc-driver/pom.xml b/java/flight/flight-jdbc-driver/pom.xml
@@ -147,12 +147,6 @@
             <artifactId>flight-sql</artifactId>
             <version>${project.version}</version>
         </dependency>
-
-        <dependency>
-            <groupId>org.apache.arrow</groupId>
-            <artifactId>arrow-format</artifactId>
-            <version>${project.version}</version>
-        </dependency>
     </dependencies>
 
     <build>

diff --git a/...apache/arrow/driver/jdbc/accessor/impl/text/ArrowFlightJdbcVarCharVectorAccessorTest.java b/...apache/arrow/driver/jdbc/accessor/impl/text/ArrowFlightJdbcVarCharVectorAccessorTest.java
@@ -17,7 +17,6 @@
 
 package org.apache.arrow.driver.jdbc.accessor.impl.text;
 
-import static org.apache.calcite.avatica.util.Cursor.Accessor;
 import static org.apache.commons.io.IOUtils.toByteArray;
 import static org.apache.commons.io.IOUtils.toCharArray;
 import static org.hamcrest.CoreMatchers.equalTo;

diff --git a/...c-driver/src/test/java/org/apache/arrow/driver/jdbc/test/adhoc/MockFlightSqlProducer.java b/...c-driver/src/test/java/org/apache/arrow/driver/jdbc/test/adhoc/MockFlightSqlProducer.java
@@ -22,7 +22,6 @@
 import static java.lang.String.format;
 import static java.util.UUID.randomUUID;
 import static java.util.stream.Collectors.toList;
-import static java.util.stream.IntStream.range;
 
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
@@ -80,7 +79,6 @@
 import org.apache.arrow.util.Preconditions;
 import org.apache.arrow.vector.VectorSchemaRoot;
 import org.apache.arrow.vector.ipc.WriteChannel;
-import org.apache.arrow.vector.ipc.message.IpcOption;
 import org.apache.arrow.vector.ipc.message.MessageSerializer;
 import org.apache.arrow.vector.types.pojo.Schema;
 import org.apache.calcite.avatica.Meta.StatementType;

diff --git a/java/flight/flight-sql/pom.xml b/java/flight/flight-sql/pom.xml
@@ -53,6 +53,16 @@
       <artifactId>arrow-format</artifactId>
       <version>${project.version}</version>
     </dependency>
+    <dependency>
+      <groupId>org.apache.arrow</groupId>
+      <artifactId>arrow-format</artifactId>
+      <version>${project.version}</version>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.arrow</groupId>
+      <artifactId>arrow-jdbc</artifactId>
+      <version>${project.version}</version>
+    </dependency>
     <dependency>
       <groupId>org.apache.arrow</groupId>
       <artifactId>arrow-jdbc</artifactId>

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
@@ -34,7 +34,7 @@
 import static org.apache.arrow.flight.sql.impl.FlightSql.DoPutUpdateResult;
 import static org.apache.arrow.flight.sql.impl.FlightSql.SqlInfo;
 
-import java.io.ByteArrayInputStream;
+import com.fasterxml.jackson.databind.util.ByteBufferBackedInputStream;
 import java.io.IOException;
 import java.nio.channels.Channels;
 import java.sql.SQLException;
@@ -514,7 +514,7 @@ private Schema deserializeSchema(final ByteString bytes) {
             new Schema(Collections.emptyList()) :
             MessageSerializer.deserializeSchema(
                 new ReadChannel(Channels.newChannel(
-                    new ByteArrayInputStream(bytes.toByteArray()))));
+                    new ByteBufferBackedInputStream(bytes.asReadOnlyByteBuffer()))));
       } catch (final IOException e) {
         throw new RuntimeException("Failed to deserialize schema", e);
       }