[arrow] branch master updated: ARROW-5750: [Java] Fix java compilation errors

[we...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

wesm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow.git


The following commit(s) were added to refs/heads/master by this push:
     new 5d12e89  ARROW-5750: [Java] Fix java compilation errors
5d12e89 is described below

commit 5d12e899c0e24793863682eb8c1c8c966990fd19
Author: Micah Kornfield <em...@gmail.com>
AuthorDate: Wed Jun 26 23:31:15 2019 -0500

    ARROW-5750: [Java] Fix java compilation errors
    
    Author: Micah Kornfield <em...@gmail.com>
    
    Closes #4713 from emkornfield/compilation_fix and squashes the following commits:
    
    5cc854dbd <Micah Kornfield> ARROW-5750: Fix java compilation errors
---
 .../src/test/java/org/apache/arrow/flight/TestFlightClient.java      | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/java/flight/src/test/java/org/apache/arrow/flight/TestFlightClient.java b/java/flight/src/test/java/org/apache/arrow/flight/TestFlightClient.java
index 273f11f..6e7ac2d 100644
--- a/java/flight/src/test/java/org/apache/arrow/flight/TestFlightClient.java
+++ b/java/flight/src/test/java/org/apache/arrow/flight/TestFlightClient.java
@@ -39,14 +39,15 @@ public class TestFlightClient {
   public void independentShutdown() throws Exception {
     try (final BufferAllocator allocator = new RootAllocator(Integer.MAX_VALUE);
         final FlightServer server = FlightTestUtil.getStartedServer(
-            port -> FlightServer.builder(allocator, Location.forGrpcInsecure(FlightTestUtil.LOCALHOST, port),
+            location -> FlightServer.builder(allocator, location,
                 new Producer(allocator)).build())) {
       final Location location = Location.forGrpcInsecure(FlightTestUtil.LOCALHOST, server.getPort());
       final Schema schema = new Schema(Collections.singletonList(Field.nullable("a", new ArrowType.Int(32, true))));
       try (final FlightClient client1 = FlightClient.builder(allocator, location).build();
           final VectorSchemaRoot root = VectorSchemaRoot.create(schema, allocator)) {
         // Use startPut as this ensures the RPC won't finish until we want it to
-        final ClientStreamListener listener = client1.startPut(FlightDescriptor.path("test"), root);
+        final ClientStreamListener listener = client1.startPut(FlightDescriptor.path("test"), root,
+            new AsyncPutListener());
         try (final FlightClient client2 = FlightClient.builder(allocator, location).build()) {
           client2.listActions().forEach(actionType -> Assert.assertNotNull(actionType.getType()));
         }