diff --git a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatasetTupleTranslator.java b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatasetTupleTranslator.java
index 27978ab..7f8b9bf6 100644
--- a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatasetTupleTranslator.java
+++ b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatasetTupleTranslator.java
@@ -282,7 +282,8 @@
             final ARecordType compressionType = (ARecordType) datasetType.getFieldTypes()[compressionIndex];
             final int schemeIndex = compressionType
                     .getFieldIndex(MetadataRecordTypes.DATASET_ARECORD_DATASET_COMPRESSION_SCHEME_FIELD_NAME);
-            return ((AString) datasetRecord.getValueByPos(schemeIndex)).getStringValue();
+            final ARecord compressionRecord = (ARecord) datasetRecord.getValueByPos(compressionIndex);
+            return ((AString) compressionRecord.getValueByPos(schemeIndex)).getStringValue();
         }
         return CompressionManager.NONE;
     }