luoyuxia commented on code in PR #23438:
URL: https://github.com/apache/flink/pull/23438#discussion_r1333768943
##########
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/PlannerCallProcedureOperation.java:
##########
@@ -237,6 +249,14 @@ private TableResultInternal procedureResultToTableResult(
tableResultType = DataTypes.ROW(DataTypes.FIELD("result",
tableResultType));
}
+ RowRowConverter rowConverter = null;
+ // if the output is struct type,
+ // we need a row converter to convert the struct value to Row
Review Comment:
Thx, I have refined the comment. First convert the struct value to RowData,
and then use the RowRowConverter convert the RowData Row. Hope it can be clear.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
