未验证 提交 d5450a1e 编写于 作者: J Jackie Tien 提交者: GitHub

[IOTDB-6134] Fill statement content in show queries for inner schema fetch

上级 b1ac40b4
......@@ -74,17 +74,21 @@ class ClusterSchemaFetchExecutor {
}
private ExecutionResult executionStatement(
Long queryId, Statement statement, MPPQueryContext context) {
long queryId, Statement statement, MPPQueryContext context) {
long timeout = context == null ? config.getQueryTimeoutThreshold() : context.getTimeOut();
String sql = context == null ? "" : "Fetch Schema for " + context.getQueryType();
if (context != null && context.getQueryType() == QueryType.READ) {
sql += ", " + context.getQueryId() + " : " + context.getSql();
}
return coordinator.execute(
statement,
queryId,
context == null ? null : context.getSession(),
"",
sql,
ClusterPartitionFetcher.getInstance(),
schemaFetcher,
context == null || context.getQueryType().equals(QueryType.WRITE)
? config.getQueryTimeoutThreshold()
: context.getTimeOut());
timeout);
}
/**
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册