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

Provide mechanism for passing HMS notification ID between transactional and non-transactional listeners.



    • Improvement
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 2.3.0, 2.4.0, 3.0.0
    • Metastore
    • None


      The HMS DB notification listener currently stores an event ID on the HMS backend DB so that external applications (such as backup apps) can request incremental notifications based on the last event ID requested.

      The HMS DB notification and backup applications are asynchronous. However, there are sometimes that applications may be required to be in sync with the latest HMS event in order to process an action. These applications will provide a listener implementation that is called by the HMS after an HMS transaction happened.

      The problem is that the listener running after the transaction (or during the non-transactional context) may need the DB event ID in order to sync all events happened previous to that event ID, but this ID is never passed to the non-transactional listeners.

      We can pass this event information through the EnvironmentContext found on each ListenerEvent implementations (such as CreateTableEvent), and send the EnvironmentContext to the non-transactional listeners to get the event ID.

      The DbNotificactionListener already knows the event ID after calling the ObjectStore.addNotificationEvent(). We just need to set this event ID to the EnvironmentContext from each of the event notifications and make sure that this EnvironmentContext is sent to the non-transactional listeners.

      Here's the code example when creating a table on create_table_core:

        if (transactionalListeners.size() > 0) {
          CreateTableEvent createTableEvent = new CreateTableEvent(tbl, true, this);
          for (MetaStoreEventListener transactionalListener : transactionalListeners) {
            transactionalListener.onCreateTable(createTableEvent);         // <- Here the notification ID is generated
        success = ms.commitTransaction();
      } finally {
        if (!success) {
          if (madeDir) {
            wh.deleteDir(tblPath, true);
        for (MetaStoreEventListener listener : listeners) {
          CreateTableEvent createTableEvent =
              new CreateTableEvent(tbl, success, this);
          listener.onCreateTable(createTableEvent);                        // <- Here we would like to consume notification ID

      We could use a specific key name that will be used on the EnvironmentContext, such as DB_NOTIFICATION_EVENT_ID.


        1. HIVE-16164.8.patch
          100 kB
          Sergio Peña
        2. HIVE-16164.7.patch
          99 kB
          Sergio Peña
        3. HIVE-16164.6.patch
          98 kB
          Sergio Peña
        4. HIVE-16164.3.patch
          90 kB
          Sergio Peña
        5. HIVE-16164.2.patch
          81 kB
          Sergio Peña
        6. HIVE-16164.1.patch
          81 kB
          Sergio Peña

        Issue Links



              spena Sergio Peña
              spena Sergio Peña
              0 Vote for this issue
              8 Start watching this issue