You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by mb...@apache.org on 2021/06/30 00:11:35 UTC

[asterixdb] 15/23: [NO ISSUE][MD] Ensure metadata node is initialized

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

mblow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git

commit 294e5ed400c12ccb0da12c6339b1948981915840
Author: Murtadha Hubail <mh...@apache.org>
AuthorDate: Wed Mar 10 01:06:17 2021 +0300

    [NO ISSUE][MD] Ensure metadata node is initialized
    
    - user model changes: no
    - storage format changes: no
    - interface changes: no
    
    Details:
    
    - Before attempting to being any metadata transaction, ensure
      the metadata node has been bound to avoid NPE.
    
    Change-Id: Ic54314e9da42b4111a1aab53d1ec355ad13922e1
    Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/10444
    Integration-Tests: Jenkins <je...@fulliautomatix.ics.uci.edu>
    Tested-by: Jenkins <je...@fulliautomatix.ics.uci.edu>
    Reviewed-by: Murtadha Hubail <mh...@apache.org>
    Reviewed-by: Ali Alsuliman <al...@gmail.com>
    (cherry picked from commit e8428051a7550578e2b28f5987e87ede41c83832)
    Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/12023
---
 .../src/main/java/org/apache/asterix/metadata/MetadataManager.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataManager.java b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataManager.java
index e5ee163..362ead8 100644
--- a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataManager.java
+++ b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataManager.java
@@ -129,6 +129,11 @@ public abstract class MetadataManager implements IMetadataManager {
 
     @Override
     public MetadataTransactionContext beginTransaction() throws RemoteException {
+        try {
+            INSTANCE.init();
+        } catch (HyracksDataException e) {
+            throw new ACIDException(e);
+        }
         TxnId txnId = createTxnId();
         metadataNode.beginTransaction(txnId);
         return new MetadataTransactionContext(txnId);