-
Notifications
You must be signed in to change notification settings - Fork 3.1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add debug log statements for pinot PQL #22221
Conversation
635c6a7
to
bc031a9
Compare
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/query/DynamicTablePqlExtractor.java
Outdated
Show resolved
Hide resolved
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/query/PinotQueryBuilder.java
Outdated
Show resolved
Hide resolved
@ebyhr done. Changed all to debug. |
e1741c8
to
aabcd63
Compare
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/PinotPageSourceProvider.java
Show resolved
Hide resolved
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/query/DynamicTablePqlExtractor.java
Outdated
Show resolved
Hide resolved
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/query/DynamicTablePqlExtractor.java
Outdated
Show resolved
Hide resolved
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/query/PinotQueryBuilder.java
Outdated
Show resolved
Hide resolved
Please update PR title. |
635cdc3
to
e1758f3
Compare
@@ -75,7 +78,7 @@ public ConnectorPageSource createPageSource( | |||
} | |||
PinotTableHandle pinotTableHandle = (PinotTableHandle) tableHandle; | |||
String query = generatePql(pinotTableHandle, handles, pinotSplit.getSuffix(), pinotSplit.getTimePredicate(), limitForSegmentQueries); | |||
|
|||
LOG.debug("Pinot query: %s", query); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The logging place looks still wrong. Note that #22253 is going to move the above generatePql
method call because it's redundant in case of dynamic tables.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
In that case let me close the PR.
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/PinotPageSourceProvider.java
Outdated
Show resolved
Hide resolved
Please use a more helpful commit title. e.g. "Add debug log for generated Pinot SQL" |
Description
To do a better debuging of Pinot performance issues we are trying to log the queries. There is no way we can do that. I do feel there should be a general approach for enabling this across but for now we desperately need this.
Additional context and related issues
The PR allows a connector setting to log the queries executed against a pinot catalog. This helps better query tracking.
Release notes
(x) This is not user-visible or is docs only, and no release notes are required.