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);