Uploaded image for project: 'Hive'
  1. Hive
  2. HIVE-12421

Streaming API add TransactionBatch.beginNextTransaction(long timeout)

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Critical
    • Resolution: Unresolved
    • 0.14.0
    • None
    • HCatalog, Transactions
    • None

    Description

      TransactionBatchImpl.beginNextTransactionImpl() has

              LockResponse res = msClient.lock(lockRequest);
              if (res.getState() != LockState.ACQUIRED) {
                throw new TransactionError("Unable to acquire lock on " + endPt);
              }
      

      This means that if there are any competing locks already taken, this will throw an Exception to client. This doesn't seem like the right behavior. It should block.

      We could also add TransactionBatch.beginNextTransaction(long timeoutMs) to give the client more control.

      cc alangates sriharsha

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              ekoifman Eugene Koifman
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: