This is an automated email from the ASF dual-hosted git repository.
bharat pushed a commit to branch ozone-0.6.0
in repository https://gitbox.apache.org/repos/asf/hadoop-ozone.git
The following commit(s) were added to refs/heads/ozone-0.6.0 by this push:
new aa18df3 HDDS-3968. LDB scan fails to read from transactionInfoTable.
(#1205)
aa18df3 is described below
commit aa18df342c11f17c1024dae08d299cf1d73ac818
Author: Bharat Viswanadham <[email protected]>
AuthorDate: Wed Jul 15 17:16:22 2020 -0700
HDDS-3968. LDB scan fails to read from transactionInfoTable. (#1205)
---
.../org/apache/hadoop/ozone/om/codec/OMDBDefinition.java | 13 ++++++++++++-
1 file changed, 12 insertions(+), 1 deletion(-)
diff --git
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/codec/OMDBDefinition.java
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/codec/OMDBDefinition.java
index f46afde..24f3341 100644
---
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/codec/OMDBDefinition.java
+++
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/codec/OMDBDefinition.java
@@ -23,6 +23,7 @@ import org.apache.hadoop.hdds.utils.db.DBDefinition;
import org.apache.hadoop.hdds.utils.db.LongCodec;
import org.apache.hadoop.hdds.utils.db.StringCodec;
import org.apache.hadoop.ozone.om.OMConfigKeys;
+import org.apache.hadoop.ozone.om.OmMetadataManagerImpl;
import org.apache.hadoop.ozone.om.helpers.OmBucketInfo;
import org.apache.hadoop.ozone.om.helpers.OmKeyInfo;
import org.apache.hadoop.ozone.om.helpers.OmVolumeArgs;
@@ -31,6 +32,7 @@ import org.apache.hadoop.ozone.om.helpers.OmMultipartKeyInfo;
import org.apache.hadoop.ozone.om.helpers.OmPrefixInfo;
import org.apache.hadoop.ozone.om.helpers.S3SecretValue;
+import org.apache.hadoop.ozone.om.ratis.OMTransactionInfo;
import org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos;
import org.apache.hadoop.ozone.security.OzoneTokenIdentifier;
@@ -139,6 +141,15 @@ public class OMDBDefinition implements DBDefinition {
S3SecretValue.class,
new S3SecretValueCodec());
+ public static final DBColumnFamilyDefinition<String, OMTransactionInfo>
+ TRANSACTION_INFO_TABLE =
+ new DBColumnFamilyDefinition<>(
+ OmMetadataManagerImpl.TRANSACTION_INFO_TABLE,
+ String.class,
+ new StringCodec(),
+ OMTransactionInfo.class,
+ new OMTransactionInfoCodec());
+
@Override
public String getName() {
@@ -155,7 +166,7 @@ public class OMDBDefinition implements DBDefinition {
return new DBColumnFamilyDefinition[] {DELETED_TABLE, USER_TABLE,
VOLUME_TABLE, S3_TABLE, OPEN_KEY_TABLE, KEY_TABLE,
BUCKET_TABLE, MULTIPART_INFO_TABLE, PREFIX_TABLE, DTOKEN_TABLE,
- S3_SECRET_TABLE};
+ S3_SECRET_TABLE, TRANSACTION_INFO_TABLE};
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
