diff --git a/asterix-metadata/src/main/java/edu/uci/ics/asterix/metadata/MetadataManager.java b/asterix-metadata/src/main/java/edu/uci/ics/asterix/metadata/MetadataManager.java
index d7e9bbb..dbfe32c 100644
--- a/asterix-metadata/src/main/java/edu/uci/ics/asterix/metadata/MetadataManager.java
+++ b/asterix-metadata/src/main/java/edu/uci/ics/asterix/metadata/MetadataManager.java
@@ -388,7 +388,11 @@
         } catch (RemoteException e) {
             throw new MetadataException(e);
         }
-        ctx.addDatatype(datatype);
+        try {
+            ctx.addDatatype(metadataNode.getDatatype(ctx.getJobId(),datatype.getDataverseName(),datatype.getDatatypeName()));
+        } catch (RemoteException e) {
+            throw new MetadataException(e);
+        }
     }
 
     @Override