cryptoe commented on code in PR #14571:
URL: https://github.com/apache/druid/pull/14571#discussion_r1285223405
##########
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/resources/SqlStatementResource.java:
##########
@@ -663,12 +666,36 @@ private MSQControllerTask
getMSQControllerTaskOrThrow(String queryId, String cur
return msqControllerTask;
}
+ /**
+ * Creates a new sqlQuery from the user submitted sqlQuery after performing
required modifications.
+ */
+ private SqlQuery createModifiedSqlQuery(SqlQuery sqlQuery)
+ {
+ Map<String, Object> context = sqlQuery.getContext();
+ if (context.containsKey(RESULT_FORMAT)) {
+ throw InvalidInput.exception("Query context parameter [%s] is not
allowed", RESULT_FORMAT);
Review Comment:
if we do this:
https://github.com/apache/druid/pull/14571#discussion_r1285222902 then I think
the error message need not change.
--
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]
