This is an automated email from the ASF dual-hosted git repository.
cwylie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new fd63e5a514 fix issue with jdbc and query metrics (#13608)
fd63e5a514 is described below
commit fd63e5a5142b458616157ce857f2c1eeae3eac2a
Author: Clint Wylie <[email protected]>
AuthorDate: Wed Dec 21 19:32:53 2022 -0800
fix issue with jdbc and query metrics (#13608)
* fix issue with metrics emitting and jdbc results by getting yielder from
query processing thread
* more better
---
.../main/java/org/apache/druid/sql/avatica/DruidJdbcResultSet.java | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git
a/sql/src/main/java/org/apache/druid/sql/avatica/DruidJdbcResultSet.java
b/sql/src/main/java/org/apache/druid/sql/avatica/DruidJdbcResultSet.java
index 70ec88ff1b..1f75a13517 100644
--- a/sql/src/main/java/org/apache/druid/sql/avatica/DruidJdbcResultSet.java
+++ b/sql/src/main/java/org/apache/druid/sql/avatica/DruidJdbcResultSet.java
@@ -26,7 +26,6 @@ import org.apache.druid.java.util.common.IAE;
import org.apache.druid.java.util.common.ISE;
import org.apache.druid.java.util.common.StringUtils;
import org.apache.druid.java.util.common.concurrent.Execs;
-import org.apache.druid.java.util.common.guava.Sequence;
import org.apache.druid.java.util.common.guava.Yielder;
import org.apache.druid.java.util.common.guava.Yielders;
import org.apache.druid.java.util.common.logger.Logger;
@@ -237,13 +236,12 @@ public class DruidJdbcResultSet implements Closeable
// Execute the first step: plan the query and return a sequence to use
// to get values.
- final Sequence<Object[]> sequence =
queryExecutor.submit(stmt::execute).get().getResults();
-
+ final Yielder<Object[]> yielder = queryExecutor.submit(() ->
Yielders.each(stmt.execute().getResults())).get();
// Subsequent fetch steps are done via the async "fetcher".
fetcher = fetcherFactory.newFetcher(
// We can't apply limits greater than Integer.MAX_VALUE, ignore them.
maxRowCount >= 0 && maxRowCount <= Integer.MAX_VALUE ? (int)
maxRowCount : Integer.MAX_VALUE,
- Yielders.each(sequence)
+ yielder
);
signature = AbstractDruidJdbcStatement.createSignature(
stmt.prepareResult(),
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
