Skip to content

Commit 23e5ca8

Browse files
committed
HfdsRepository
1 parent e2665d1 commit 23e5ca8

File tree

3 files changed

+8
-13
lines changed

3 files changed

+8
-13
lines changed

plugins/repository-hdfs/src/main/java/org/elasticsearch/repositories/hdfs/HdfsPlugin.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,8 @@ public Map<String, Repository.Factory> getRepositories(
8080
namedXContentRegistry,
8181
clusterService,
8282
bigArrays,
83-
recoverySettings
83+
recoverySettings,
84+
snapshotMetrics
8485
)
8586
);
8687
}

plugins/repository-hdfs/src/main/java/org/elasticsearch/repositories/hdfs/HdfsRepository.java

Lines changed: 3 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -64,18 +64,10 @@ public HdfsRepository(
6464
NamedXContentRegistry namedXContentRegistry,
6565
ClusterService clusterService,
6666
BigArrays bigArrays,
67-
RecoverySettings recoverySettings
67+
RecoverySettings recoverySettings,
68+
SnapshotMetrics snapshotMetrics
6869
) {
69-
super(
70-
projectId,
71-
metadata,
72-
namedXContentRegistry,
73-
clusterService,
74-
bigArrays,
75-
recoverySettings,
76-
BlobPath.EMPTY,
77-
SnapshotMetrics.NOOP
78-
);
70+
super(projectId, metadata, namedXContentRegistry, clusterService, bigArrays, recoverySettings, BlobPath.EMPTY, snapshotMetrics);
7971

8072
this.environment = environment;
8173
this.chunkSize = metadata.settings().getAsBytesSize("chunk_size", null);

plugins/repository-hdfs/src/test/java/org/elasticsearch/repositories/hdfs/HdfsBlobStoreContainerTests.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@
3030
import org.elasticsearch.core.SuppressForbidden;
3131
import org.elasticsearch.env.Environment;
3232
import org.elasticsearch.indices.recovery.RecoverySettings;
33+
import org.elasticsearch.repositories.SnapshotMetrics;
3334
import org.elasticsearch.repositories.blobstore.BlobStoreTestUtil;
3435
import org.elasticsearch.test.ESTestCase;
3536
import org.elasticsearch.test.fixtures.hdfs.HdfsClientThreadLeakFilter;
@@ -126,7 +127,8 @@ public void testRepositoryProjectId() {
126127
NamedXContentRegistry.EMPTY,
127128
BlobStoreTestUtil.mockClusterService(),
128129
MockBigArrays.NON_RECYCLING_INSTANCE,
129-
new RecoverySettings(Settings.EMPTY, new ClusterSettings(Settings.EMPTY, ClusterSettings.BUILT_IN_CLUSTER_SETTINGS))
130+
new RecoverySettings(Settings.EMPTY, new ClusterSettings(Settings.EMPTY, ClusterSettings.BUILT_IN_CLUSTER_SETTINGS)),
131+
SnapshotMetrics.NOOP
130132
);
131133
assertThat(repository.getProjectId(), equalTo(projectId));
132134
}

0 commit comments

Comments
 (0)