File tree Expand file tree Collapse file tree 2 files changed +3
-1
lines changed
fe/fe-core/src/main/java/org/apache/doris/datasource/argo/source Expand file tree Collapse file tree 2 files changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -58,6 +58,7 @@ protected void createScanRangeLocations() throws UserException {
5858 protected void toThrift (TPlanNode msg ) {
5959 msg .node_type = TPlanNodeType .ARGO_SCAN_NODE ;
6060 msg .argo_scan_node = new TArgoScanNode ();
61+ msg .argo_scan_node .setTupleId (desc .getId ().asInt ());
6162 msg .argo_scan_node .setTableName (table .getName ());
6263 super .toThrift (msg );
6364 }
Original file line number Diff line number Diff line change @@ -751,7 +751,8 @@ struct TTestExternalScanNode {
751751}
752752
753753struct TArgoScanNode {
754- 1: optional string table_name
754+ 1: required Types.TTupleId tuple_id
755+ 2: optional string table_name
755756}
756757
757758struct TSortInfo {
You can’t perform that action at this time.
0 commit comments