From 02bcbe38db17ca131108c0056fa2930532d8ba90 Mon Sep 17 00:00:00 2001 From: Xinyi Zou Date: Mon, 30 Oct 2023 17:22:21 +0800 Subject: [PATCH] 5 --- .../doris/service/arrowflight/DorisFlightSqlProducer.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/DorisFlightSqlProducer.java b/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/DorisFlightSqlProducer.java index 7b9ab13cc585758..9a65a4982aa7390 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/DorisFlightSqlProducer.java +++ b/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/DorisFlightSqlProducer.java @@ -149,9 +149,10 @@ public FlightInfo getFlightInfoStatement(final CommandStatementQuery request, fi TicketStatementQuery ticketStatement = TicketStatementQuery.newBuilder() .setStatementHandle(handle).build(); return getFlightInfoForSchema(ticketStatement, descriptor, - jdbcToArrowSchema(flightSqlChannel.getResultSet(DebugUtil.printId(connectContext.queryId())) - .getResultSet() - .getMetaData(), DEFAULT_CALENDAR)); + JdbcToArrowUtils.jdbcToArrowSchema( + flightSqlChannel.getResultSet(DebugUtil.printId(connectContext.queryId())) + .getResultSet() + .getMetaData(), DEFAULT_CALENDAR)); } else { final ByteString handle = ByteString.copyFromUtf8( DebugUtil.printId(connectContext.getFinstId()) + ":" + query);