Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

mask more

This commit is contained in:
Zoltan Haindrich 2024-08-05 14:19:52 +00:00
parent 4c722f271f
commit 181458c873
2 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
extensions-core/multi-stage-query/src/test/java/org/apache/druid/sql/avatica/MSQDruidMeta.java
View File

@ -93,7 +93,11 @@ public class MSQDruidMeta extends DruidMeta
String str = objectMapper
.writerWithDefaultPrettyPrinter()
.writeValueAsString(payload.getStages());
str = str.replaceAll(taskId, "<taskId>");
str = str.replaceAll(taskId, "<taskId>")
.replaceAll("\"startTime\" : .*", "\"startTime\" : __TIMESTAMP__")
.replaceAll("\"duration\" : .*", "\"duration\" : __DURATION__")
.replaceAll("\"sqlQueryId\" : .*", "\"sqlQueryId\" : __SQL_QUERY_ID__");
hookDispatcher.dispatch(DruidHook.MSQ_PLAN, str);
}
catch (JsonProcessingException e) {

12
extensions-core/multi-stage-query/src/test/quidem/org.apache.druid.msq.exec.MSQQuidemTest/msq1.iq
View File

@ -94,7 +94,7 @@ order by 1;
"finalize" : true,
"maxParseExceptions" : 0,
"plannerStrategy" : "DECOUPLED",
"sqlQueryId" : "1e9ae92b-02e5-4506-be2e-8d89ce1dc77d",
"sqlQueryId" : __SQL_QUERY_ID__
"sqlStringifyArrays" : false
}
}
@ -127,8 +127,8 @@ order by 1;
"partitionCount" : 1,
"shuffle" : "globalSort",
"output" : "localStorage",
"startTime" : "2024-07-26T04:26:29.003Z",
"duration" : 724,
"startTime" : __TIMESTAMP__
"duration" : __DURATION__
"sort" : true
}, {
"stageNumber" : 1,
@ -200,7 +200,7 @@ order by 1;
"finalize" : true,
"maxParseExceptions" : 0,
"plannerStrategy" : "DECOUPLED",
"sqlQueryId" : "1e9ae92b-02e5-4506-be2e-8d89ce1dc77d",
"sqlQueryId" : __SQL_QUERY_ID__
"sqlStringifyArrays" : false
}
}
@ -221,8 +221,8 @@ order by 1;
"workerCount" : 1,
"partitionCount" : 1,
"output" : "localStorage",
"startTime" : "2024-07-26T04:26:29.727Z",
"duration" : 2
"startTime" : __TIMESTAMP__
"duration" : __DURATION__
} ]
!msqPlan
# 227