This is not specific to Flight; use jstack or your favorite instrumentation
tool (VisualVM etc.)
On Wed, Apr 30, 2025, at 15:41, NIKHIL RANJAN wrote:
> Hi David,
>
> How to enable thread dump logs for both client and server code.
>
> As of now, I don't see any error on either client side or server side. It
> just hangs/gets stuck.
>
> Thanks,
> Nikhil
>
> On Thu, 24 Apr, 2025, 14:39 Susmit Sarkar, <susmitsir...@gmail.com> wrote:
>
>> Hi Team,
>>
>> We are using this below code snippet in Scala to query the flight server,
>> but seems to be stuck indefinitely, this issue is seen when we are testing
>> from our local workstation (Mac to be precise)
>>
>> Another interesting thing, it's able to propagate the error message
>> correctly but not the FlightStream data, the same code works fine when we
>> run inside a linux VM.
>>
>> Do you folks see any issue in the code?
>>
>> def fetchDataStreamIterator(details: BaseDataAccessDetails):
>> Iterator[FlightStream] = {
>> logger.info(s"Fetching data for details: ${details.toString}")
>> val ticketStr = buildTicketStr(details)
>> logger.info(s"Generated ticket string: $ticketStr")
>>
>> val allocator = new RootAllocator(Long.MaxValue)
>> val client = FlightClient.builder(allocator,
>> Location.forGrpcInsecure(serverHost, serverPort)).build()
>>
>> try {
>> val ticket = new Ticket(ticketStr.getBytes(StandardCharsets.UTF_8))
>> val stream = client.getStream(ticket)
>>
>> Iterator.continually {
>> if (stream.next()) Some(stream) else {
>> // Cleanup when no more batches
>> close(stream, client)
>> None
>> }
>> }.takeWhile(_.isDefined).flatten
>> } catch {
>> case e: FlightRuntimeException =>
>> logger.error(s"Error communicating with Flight server:
>> ${e.getMessage}")
>> throw new CefFlightServerException(s"Error communicating with Flight
>> server: ${e.getMessage}", e)
>> case e: Exception =>
>> logger.error(s"Failed to fetch data: ${e.getMessage}")
>> throw new CefFlightServerException("Failed to fetch data from Flight
>> Server", e)
>> }
>> }
>>
>>
>> Thanks,
>>
>> Susmit
>>
>>
