From 5d71b7dfebc3041076dec8d61318ef87b6184766 Mon Sep 17 00:00:00 2001 From: Sutou Kouhei Date: Tue, 1 Aug 2023 17:18:13 +0900 Subject: [PATCH] Use POLL_FLIGHT_INFO --- .../src/main/java/org/apache/arrow/flight/FlightMethod.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/java/flight/flight-core/src/main/java/org/apache/arrow/flight/FlightMethod.java b/java/flight/flight-core/src/main/java/org/apache/arrow/flight/FlightMethod.java index 11f0ae1df8744..b1331a8edd60f 100644 --- a/java/flight/flight-core/src/main/java/org/apache/arrow/flight/FlightMethod.java +++ b/java/flight/flight-core/src/main/java/org/apache/arrow/flight/FlightMethod.java @@ -32,6 +32,7 @@ public enum FlightMethod { DO_ACTION, LIST_ACTIONS, DO_EXCHANGE, + POLL_FLIGHT_INFO, ; /** @@ -59,7 +60,7 @@ public static FlightMethod fromProtocol(final String methodName) { } else if (FlightServiceGrpc.getDoExchangeMethod().getFullMethodName().equals(methodName)) { return DO_EXCHANGE; } else if (FlightServiceGrpc.getPollFlightInfoMethod().getFullMethodName().equals(methodName)) { - return DO_EXCHANGE; + return POLL_FLIGHT_INFO; } throw new IllegalArgumentException("Not a Flight method name in gRPC: " + methodName); }