You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by dm...@apache.org on 2020/07/28 13:02:49 UTC
[hive] branch master updated: HIVE-23874: Add debug line for
fetchRequest in the HiveQueryResultSet (Hunter Logan,
reviewed by David Mollitor)
This is an automated email from the ASF dual-hosted git repository.
dmollitor pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/master by this push:
new 51e0d72 HIVE-23874: Add debug line for fetchRequest in the HiveQueryResultSet (Hunter Logan, reviewed by David Mollitor)
51e0d72 is described below
commit 51e0d7233c7df97b6b8fc3f243116b914db91c87
Author: Hunter Logan <hu...@outlook.com>
AuthorDate: Tue Jul 28 09:02:37 2020 -0400
HIVE-23874: Add debug line for fetchRequest in the HiveQueryResultSet (Hunter Logan, reviewed by David Mollitor)
---
jdbc/src/java/org/apache/hive/jdbc/HiveQueryResultSet.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/jdbc/src/java/org/apache/hive/jdbc/HiveQueryResultSet.java b/jdbc/src/java/org/apache/hive/jdbc/HiveQueryResultSet.java
index df31a25..34ec66b 100644
--- a/jdbc/src/java/org/apache/hive/jdbc/HiveQueryResultSet.java
+++ b/jdbc/src/java/org/apache/hive/jdbc/HiveQueryResultSet.java
@@ -332,7 +332,7 @@ public class HiveQueryResultSet extends HiveBaseResultSet {
try {
TFetchOrientation orientation = TFetchOrientation.FETCH_NEXT;
if (fetchFirst) {
- // If we are asked to start from begining, clear the current fetched resultset
+ // If we are asked to start from beginning, clear the current fetched resultset
orientation = TFetchOrientation.FETCH_FIRST;
fetchedRows = null;
fetchedRowsItr = null;
@@ -341,6 +341,7 @@ public class HiveQueryResultSet extends HiveBaseResultSet {
if (fetchedRows == null || !fetchedRowsItr.hasNext()) {
TFetchResultsReq fetchReq = new TFetchResultsReq(stmtHandle,
orientation, fetchSize);
+ LOG.debug("HiveQueryResultsFetchReq: {}", fetchReq);
TFetchResultsResp fetchResp;
fetchResp = client.FetchResults(fetchReq);
Utils.verifySuccessWithInfo(fetchResp.getStatus());