Job Result Can't be Viewed

1

After querying a saved dataset on S3, the job was completed successfully. But the UI show error instead of viewing the result.

After investigation I found this exception in the server logs
2020-07-06 16:57:10,031 [qtp2062253014-174243] ERROR c.d.d.server.GenericExceptionMapper - Unexpected exception when processing GET http://dremio.basharsoft.com/apiv2/job/20fca81a-cf9a-a633-1e57-2e93df0f5d00/data?offset=0&limit=100 : org.apache.arrow.flight.FlightRuntimeException: CallStatus{code=UNKNOWN, cause=null, description=‘NULL’, metadata=‘org.apache.arrow.flight.ErrorFlightMetadata@5b0a8438’}
org.apache.arrow.flight.FlightRuntimeException: NULL
at org.apache.arrow.flight.CallStatus.toRuntimeException(CallStatus.java:131)
at org.apache.arrow.flight.grpc.StatusUtils.fromGrpcRuntimeException(StatusUtils.java:152)
at org.apache.arrow.flight.grpc.StatusUtils.fromThrowable(StatusUtils.java:176)
at org.apache.arrow.flight.FlightStream$Observer.onError(FlightStream.java:370)
at org.apache.arrow.flight.FlightClient$1.onError(FlightClient.java:281)
at io.grpc.stub.ClientCalls$StreamObserverToCallListenerAdapter.onClose(ClientCalls.java:442)
at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
at org.apache.arrow.flight.grpc.ClientInterceptorAdapter$FlightClientCallListener.onClose(ClientInterceptorAdapter.java:117)
at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:510)
at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:66)
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.close(ClientCallImpl.java:630)
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.access$700(ClientCallImpl.java:518)
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:692)
at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:681)
at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)

The job profile: b5218ba8-a577-426a-bce5-43c9ec448670.zip (18.9 KB)

The queried dataset dataset.zip (13.2 KB)

2

Another example of the same error

SELECT KVGEN(changeset) 
FROM (
SELECT convert_from("EXPR$0", 'JSON') AS "changeset"
FROM (
  SELECT '{
     "has_bike":{
        "old":false
     },
     "show_salary":{
        "old":false
     },
     "is_shift":{
        "new":true,
        "old":false
     },
     "shift_type":{
        "new":"1"
     },
     "is_accommodation":{
        "new":false,
        "old":true
     },
     "is_social_insurance":{
        "new":"0"
     }
  }'
) nested_0
) t
3

@elshafey

Thanks for providing the Parquet file, able to reproduce the error, will look into this and get back to you

Thanks
Bali

1 Like