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

lidavidm 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 26f2d877b5 MINOR: [Java][Flight] Add context of descriptor on 
integration tests when not found
26f2d877b5 is described below

commit 26f2d877b5d08d2a9c3c7289efcd4a56ba068e26
Author: Raúl Cumplido <[email protected]>
AuthorDate: Tue May 3 12:03:29 2022 -0400

    MINOR: [Java][Flight] Add context of descriptor on integration tests when 
not found
    
    This PR adds minor logging info about the descriptor looked up when it 
can't be found.
    
    For example on this ticket failure 
[ARROW-16441](https://issues.apache.org/jira/browse/ARROW-16441) we should be 
able to get more info around the descriptor:
    
    ```
    panic: rpc error: code = NotFound desc = Unknown descriptor.
    ```
    
    Closes #13053 from raulcd/add-descriptor-info-to-not-found
    
    Authored-by: Raúl Cumplido <[email protected]>
    Signed-off-by: David Li <[email protected]>
---
 .../org/apache/arrow/flight/integration/tests/IntegrationProducer.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/IntegrationProducer.java
 
b/java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/IntegrationProducer.java
index 5f06c70049..aed3045acc 100644
--- 
a/java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/IntegrationProducer.java
+++ 
b/java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/IntegrationProducer.java
@@ -97,7 +97,7 @@ public class IntegrationProducer extends NoOpFlightProducer 
implements AutoClose
   public FlightInfo getFlightInfo(CallContext context, FlightDescriptor 
descriptor) {
     Dataset h = datasets.get(descriptor);
     if (h == null) {
-      throw CallStatus.NOT_FOUND.withDescription("Unknown 
descriptor.").toRuntimeException();
+      throw CallStatus.NOT_FOUND.withDescription("Unknown descriptor: " + 
descriptor).toRuntimeException();
     }
     return h.getFlightInfo(location);
   }

Reply via email to