[hive] branch master updated: HIVE-24077: Streaming Ingest v2 does not send heartbeats (Steve Carlin, reviewed by Jesus Camacho Rodriguez)

[jcamacho]

This is an automated email from the ASF dual-hosted git repository.

jcamacho 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 975c832  HIVE-24077: Streaming Ingest v2 does not send heartbeats 
(Steve Carlin, reviewed by Jesus Camacho Rodriguez)
975c832 is described below

commit 975c832b6d069559c5b406a4aa8def3180fe4e75
Author: scarlin-cloudera <55709772+scarlin-cloud...@users.noreply.github.com>
AuthorDate: Thu Sep 17 19:22:06 2020 -0700

    HIVE-24077: Streaming Ingest v2 does not send heartbeats (Steve Carlin, 
reviewed by Jesus Camacho Rodriguez)
    
    The setupHeartbeat routine was being called before some variables
    were initialized.
    
    Closes apache/hive#1505
---
 streaming/src/java/org/apache/hive/streaming/TransactionBatch.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/streaming/src/java/org/apache/hive/streaming/TransactionBatch.java 
b/streaming/src/java/org/apache/hive/streaming/TransactionBatch.java
index 40239ab..9215e1b 100644
--- a/streaming/src/java/org/apache/hive/streaming/TransactionBatch.java
+++ b/streaming/src/java/org/apache/hive/streaming/TransactionBatch.java
@@ -114,8 +114,6 @@ public class TransactionBatch extends 
AbstractStreamingTransaction {
       this.numTxns = conn.getTransactionBatchSize();
       this.tableId = conn.getTable().getTTable().getId();
 
-      setupHeartBeatThread();
-
       List<Long> txnIds = openTxnImpl(username, numTxns);
       txnToWriteIds = allocateWriteIdsImpl(txnIds);
       assert (txnToWriteIds.size() == numTxns);
@@ -132,6 +130,7 @@ public class TransactionBatch extends 
AbstractStreamingTransaction {
           txnToWriteIds.get(numTxns - 1).getWriteId(), conn.getStatementId());
       this.minTxnId = new AtomicLong(txnIds.get(0));
       this.maxTxnId = txnIds.get(txnIds.size() - 1);
+      setupHeartBeatThread();
       success = true;
     } catch (TException e) {
       throw new StreamingException(conn.toString(), e);