5

xinyiZzz · Oct 30, 2023 · 02bcbe3 · 02bcbe3
1 parent 4eb341e
commit 02bcbe3
Showing 1 changed file with 4 additions and 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
@@ -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);