This is an automated email from the ASF dual-hosted git repository.
rongr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 7dcae9208e 10737: Fix for SQL parsing error in multistage (#10738)
7dcae9208e is described below
commit 7dcae9208e7f297fa559fd7e59be9ffeec09d14f
Author: Abhishek Sharma <[email protected]>
AuthorDate: Sun May 7 14:06:13 2023 -0400
10737: Fix for SQL parsing error in multistage (#10738)
---
.../pinot/controller/api/resources/PinotQueryResource.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git
a/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotQueryResource.java
b/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotQueryResource.java
index d2b5de2dcb..8f56865873 100644
---
a/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotQueryResource.java
+++
b/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotQueryResource.java
@@ -68,6 +68,7 @@ import org.apache.pinot.spi.utils.builder.TableNameBuilder;
import org.apache.pinot.sql.parsers.CalciteSqlCompiler;
import org.apache.pinot.sql.parsers.CalciteSqlParser;
import org.apache.pinot.sql.parsers.PinotSqlType;
+import org.apache.pinot.sql.parsers.SqlCompilationException;
import org.apache.pinot.sql.parsers.SqlNodeAndOptions;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -129,7 +130,13 @@ public class PinotQueryResource {
private String executeSqlQuery(@Context HttpHeaders httpHeaders, String
sqlQuery, String traceEnabled,
@Nullable String queryOptions, String endpointUrl)
throws Exception {
- SqlNodeAndOptions sqlNodeAndOptions =
CalciteSqlParser.compileToSqlNodeAndOptions(sqlQuery);
+ SqlNodeAndOptions sqlNodeAndOptions;
+ try {
+ sqlNodeAndOptions =
CalciteSqlParser.compileToSqlNodeAndOptions(sqlQuery);
+ } catch (SqlCompilationException ex) {
+ return QueryException.getException(QueryException.SQL_PARSING_ERROR,
+ new Exception("Unable to parse the SQL")).toString();
+ }
Map<String, String> options = sqlNodeAndOptions.getOptions();
if (queryOptions != null) {
Map<String, String> optionsFromString =
RequestUtils.getOptionsFromString(queryOptions);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
