This is an automated email from the ASF dual-hosted git repository.
kturner pushed a commit to branch elasticity
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/elasticity by this push:
new a6f1073ac9 sets initial fate table config (#4320)
a6f1073ac9 is described below
commit a6f1073ac9b95a4a36508e018ac6f24fa499c37f
Author: Keith Turner <[email protected]>
AuthorDate: Wed Feb 28 16:32:19 2024 -0500
sets initial fate table config (#4320)
---
.../accumulo/server/init/InitialConfiguration.java | 44 +++++++++++-----------
1 file changed, 23 insertions(+), 21 deletions(-)
diff --git
a/server/base/src/main/java/org/apache/accumulo/server/init/InitialConfiguration.java
b/server/base/src/main/java/org/apache/accumulo/server/init/InitialConfiguration.java
index e932e0af15..81f2876db5 100644
---
a/server/base/src/main/java/org/apache/accumulo/server/init/InitialConfiguration.java
+++
b/server/base/src/main/java/org/apache/accumulo/server/init/InitialConfiguration.java
@@ -49,26 +49,30 @@ class InitialConfiguration {
this.hadoopConf = hadoopConf;
this.siteConf = siteConf;
-
initialRootMetaConf.put(Property.TABLE_FILE_COMPRESSED_BLOCK_SIZE.getKey(),
"32K");
- initialRootMetaConf.put(Property.TABLE_FILE_REPLICATION.getKey(), "5");
- initialRootMetaConf.put(Property.TABLE_DURABILITY.getKey(), "sync");
- initialRootMetaConf.put(Property.TABLE_MAJC_RATIO.getKey(), "1");
- initialRootMetaConf.put(Property.TABLE_SPLIT_THRESHOLD.getKey(), "64M");
- initialRootMetaConf.put(Property.TABLE_CONSTRAINT_PREFIX.getKey() + "1",
- MetadataConstraints.class.getName());
- initialRootMetaConf.put(Property.TABLE_ITERATOR_PREFIX.getKey() +
"scan.vers",
+ // config common to all Accumulo tables
+ Map<String,String> commonConfig = new HashMap<>();
+ commonConfig.put(Property.TABLE_FILE_COMPRESSED_BLOCK_SIZE.getKey(),
"32K");
+ commonConfig.put(Property.TABLE_FILE_REPLICATION.getKey(), "5");
+ commonConfig.put(Property.TABLE_DURABILITY.getKey(), "sync");
+ commonConfig.put(Property.TABLE_MAJC_RATIO.getKey(), "1");
+ commonConfig.put(Property.TABLE_ITERATOR_PREFIX.getKey() + "scan.vers",
"10," + VersioningIterator.class.getName());
- initialRootMetaConf.put(Property.TABLE_ITERATOR_PREFIX.getKey() +
"scan.vers.opt.maxVersions",
- "1");
- initialRootMetaConf.put(Property.TABLE_ITERATOR_PREFIX.getKey() +
"minc.vers",
+ commonConfig.put(Property.TABLE_ITERATOR_PREFIX.getKey() +
"scan.vers.opt.maxVersions", "1");
+ commonConfig.put(Property.TABLE_ITERATOR_PREFIX.getKey() + "minc.vers",
"10," + VersioningIterator.class.getName());
- initialRootMetaConf.put(Property.TABLE_ITERATOR_PREFIX.getKey() +
"minc.vers.opt.maxVersions",
- "1");
- initialRootMetaConf.put(Property.TABLE_ITERATOR_PREFIX.getKey() +
"majc.vers",
+ commonConfig.put(Property.TABLE_ITERATOR_PREFIX.getKey() +
"minc.vers.opt.maxVersions", "1");
+ commonConfig.put(Property.TABLE_ITERATOR_PREFIX.getKey() + "majc.vers",
"10," + VersioningIterator.class.getName());
- initialRootMetaConf.put(Property.TABLE_ITERATOR_PREFIX.getKey() +
"majc.vers.opt.maxVersions",
- "1");
- initialRootMetaConf.put(Property.TABLE_FAILURES_IGNORE.getKey(), "false");
+ commonConfig.put(Property.TABLE_ITERATOR_PREFIX.getKey() +
"majc.vers.opt.maxVersions", "1");
+ commonConfig.put(Property.TABLE_FAILURES_IGNORE.getKey(), "false");
+ commonConfig.put(Property.TABLE_DEFAULT_SCANTIME_VISIBILITY.getKey(), "");
+ commonConfig.put(Property.TABLE_INDEXCACHE_ENABLED.getKey(), "true");
+ commonConfig.put(Property.TABLE_BLOCKCACHE_ENABLED.getKey(), "true");
+
+ initialRootMetaConf.putAll(commonConfig);
+ initialRootMetaConf.put(Property.TABLE_SPLIT_THRESHOLD.getKey(), "64M");
+ initialRootMetaConf.put(Property.TABLE_CONSTRAINT_PREFIX.getKey() + "1",
+ MetadataConstraints.class.getName());
initialRootMetaConf.put(Property.TABLE_LOCALITY_GROUP_PREFIX.getKey() +
"tablet",
String.format("%s,%s",
MetadataSchema.TabletsSection.TabletColumnFamily.NAME,
MetadataSchema.TabletsSection.CurrentLocationColumnFamily.NAME));
@@ -78,11 +82,9 @@ class InitialConfiguration {
MetadataSchema.TabletsSection.ServerColumnFamily.NAME,
MetadataSchema.TabletsSection.FutureLocationColumnFamily.NAME));
initialRootMetaConf.put(Property.TABLE_LOCALITY_GROUPS.getKey(),
"tablet,server");
-
initialRootMetaConf.put(Property.TABLE_DEFAULT_SCANTIME_VISIBILITY.getKey(),
"");
- initialRootMetaConf.put(Property.TABLE_INDEXCACHE_ENABLED.getKey(),
"true");
- initialRootMetaConf.put(Property.TABLE_BLOCKCACHE_ENABLED.getKey(),
"true");
- // ELASTICITY_TODO configure initial fate table config
+ initialFateTableConf.putAll(commonConfig);
+ initialFateTableConf.put(Property.TABLE_SPLIT_THRESHOLD.getKey(), "256M");
int max = hadoopConf.getInt("dfs.replication.max", 512);
// Hadoop 0.23 switched the min value configuration name