Fix Flight SQL and Flight JDBC rebase mismatch (apache#166)

rafael-telles · Jan 19, 2022 · c54d1f9 · c54d1f9
1 parent 24688cd
commit c54d1f9
Showing 1 changed file with 2 additions and 2 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
@@ -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 com.fasterxml.jackson.databind.util.ByteBufferBackedInputStream;
+import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.nio.channels.Channels;
 import java.sql.SQLException;
@@ -559,7 +559,7 @@ private Schema deserializeSchema(final ByteString bytes) {
             new Schema(Collections.emptyList()) :
             MessageSerializer.deserializeSchema(
                 new ReadChannel(Channels.newChannel(
-                    new ByteBufferBackedInputStream(bytes.asReadOnlyByteBuffer()))));
+                    new ByteArrayInputStream(bytes.toByteArray()))));
       } catch (final IOException e) {
         throw new RuntimeException("Failed to deserialize schema", e);
       }