You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by br...@apache.org on 2015/01/01 18:01:25 UTC

svn commit: r1648889 - /hive/trunk/beeline/src/java/org/apache/hive/beeline/Commands.java

Author: brock
Date: Thu Jan  1 17:01:25 2015
New Revision: 1648889

URL: http://svn.apache.org/r1648889
Log:
HIVE-9226 - Beeline interweaves the query result and query log sometimes (Dong Chen via Brock)

Modified:
    hive/trunk/beeline/src/java/org/apache/hive/beeline/Commands.java

Modified: hive/trunk/beeline/src/java/org/apache/hive/beeline/Commands.java
URL: http://svn.apache.org/viewvc/hive/trunk/beeline/src/java/org/apache/hive/beeline/Commands.java?rev=1648889&r1=1648888&r2=1648889&view=diff
==============================================================================
--- hive/trunk/beeline/src/java/org/apache/hive/beeline/Commands.java (original)
+++ hive/trunk/beeline/src/java/org/apache/hive/beeline/Commands.java Thu Jan  1 17:01:25 2015
@@ -780,6 +780,7 @@ public class Commands {
             logThread.start();
             hasResults = stmnt.execute(sql);
             logThread.interrupt();
+            logThread.join(DEFAULT_QUERY_PROGRESS_THREAD_TIMEOUT);
           }
         }
 
@@ -847,6 +848,7 @@ public class Commands {
               return;
             } catch (InterruptedException e) {
               beeLine.debug("Getting log thread is interrupted, since query is done!");
+              showRemainingLogsIfAny(hiveStatement);
               return;
             }
           }