zzzzzzzs commented on code in PR #22509:
URL: https://github.com/apache/doris/pull/22509#discussion_r1286510505
##########
fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java:
##########
@@ -1812,6 +1844,106 @@ public TStreamLoadMultiTablePutResult
streamLoadMultiTablePut(TStreamLoadPutRequ
return result;
}
+ public class ReportStreamLoadWorker implements Runnable {
Review Comment:
Remove this first, it shouldn't be necessary
##########
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java:
##########
@@ -252,6 +256,7 @@ public class Coordinator {
public List<RuntimeFilter> assignedRuntimeFilters = new ArrayList<>();
// Runtime filter ID to the builder instance number
public Map<RuntimeFilterId, Integer> ridToBuilderNum = Maps.newHashMap();
+ ConnectContext context;
Review Comment:
done
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
