yiguolei commented on code in PR #38701:
URL: https://github.com/apache/doris/pull/38701#discussion_r1701228400
##########
fe/fe-core/src/main/java/org/apache/doris/planner/SchemaScanNode.java:
##########
@@ -96,6 +100,17 @@ public void finalizeForNereids() throws UserException {
frontendPort = Config.rpc_port;
}
+ private void setOtherFeIp(TPlanNode msg) {
Review Comment:
在SchemaTable中增加一个属性，表示这个table 是否支持从多个fe 上获取元数据。
put("processlist",
new SchemaTable(SystemIdGenerator.getNextId(),
"processlist", TableType.SCHEMA,
builder().column("CURRENT_CONNECTED",
ScalarType.createVarchar(16))
.column("ID",
ScalarType.createType(PrimitiveType.LARGEINT))
.column("USER",
ScalarType.createVarchar(32))
.column("HOST",
ScalarType.createVarchar(261))
.column("LOGIN_TIME",
ScalarType.createType(PrimitiveType.DATETIMEV2))
.column("CATALOG",
ScalarType.createVarchar(64))
.column("DB",
ScalarType.createVarchar(64))
.column("COMMAND",
ScalarType.createVarchar(16))
.column("TIME",
ScalarType.createType(PrimitiveType.INT))
.column("STATE",
ScalarType.createVarchar(64))
.column("QUERY_ID",
ScalarType.createVarchar(256))
.column("INFO",
ScalarType.createVarchar(ScalarType.MAX_VARCHAR_LENGTH))
.column("FE",
ScalarType.createVarchar(64)).build()))
在这里new 这个table的时候，把这个属性设置为true。
此时这里判断一下，当前table 是否有这个属性，如果有的话，就多fe，没有的话，就不设置了
--
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: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
