diff --git a/modules/repository-url/src/main/java/org/elasticsearch/common/blobstore/url/URLBlobContainer.java b/modules/repository-url/src/main/java/org/elasticsearch/common/blobstore/url/URLBlobContainer.java index 9b5ae6dbc0a38..4c159b1ce3b40 100644 --- a/modules/repository-url/src/main/java/org/elasticsearch/common/blobstore/url/URLBlobContainer.java +++ b/modules/repository-url/src/main/java/org/elasticsearch/common/blobstore/url/URLBlobContainer.java @@ -169,4 +169,8 @@ public void compareAndExchangeRegister( listener.onFailure(new UnsupportedOperationException("URL repositories do not support this operation")); } + @Override + public void getRegister(OperationPurpose purpose, String key, ActionListener listener) { + listener.onFailure(new UnsupportedOperationException("URL repositories do not support this operation")); + } } diff --git a/plugins/repository-hdfs/src/main/java/org/elasticsearch/repositories/hdfs/HdfsBlobContainer.java b/plugins/repository-hdfs/src/main/java/org/elasticsearch/repositories/hdfs/HdfsBlobContainer.java index b1342a63c71a4..3317d1462cc69 100644 --- a/plugins/repository-hdfs/src/main/java/org/elasticsearch/repositories/hdfs/HdfsBlobContainer.java +++ b/plugins/repository-hdfs/src/main/java/org/elasticsearch/repositories/hdfs/HdfsBlobContainer.java @@ -334,6 +334,11 @@ public void compareAndExchangeRegister( listener.onFailure(new UnsupportedOperationException("HDFS repositories do not support this operation")); } + @Override + public void getRegister(OperationPurpose purpose, String key, ActionListener listener) { + listener.onFailure(new UnsupportedOperationException("HDFS repositories do not support this operation")); + } + private static CreateOpts[] addOptionToArray(final CreateOpts[] opts, final CreateOpts opt) { if (opts == null) { return new CreateOpts[] { opt }; diff --git a/server/src/main/java/org/elasticsearch/common/blobstore/BlobContainer.java b/server/src/main/java/org/elasticsearch/common/blobstore/BlobContainer.java index c20d9832daf0a..2bf23b2c30c30 100644 --- a/server/src/main/java/org/elasticsearch/common/blobstore/BlobContainer.java +++ b/server/src/main/java/org/elasticsearch/common/blobstore/BlobContainer.java @@ -11,7 +11,6 @@ import org.elasticsearch.action.ActionListener; import org.elasticsearch.common.blobstore.support.BlobMetadata; -import org.elasticsearch.common.bytes.BytesArray; import org.elasticsearch.common.bytes.BytesReference; import org.elasticsearch.core.CheckedConsumer; import org.elasticsearch.repositories.blobstore.BlobStoreRepository; @@ -377,9 +376,7 @@ default void compareAndSetRegister( * @param listener a listener, completed with the value read from the register or {@code OptionalBytesReference#MISSING} if the value * could not be read due to concurrent activity (which should not happen). */ - default void getRegister(OperationPurpose purpose, String key, ActionListener listener) { - compareAndExchangeRegister(purpose, key, BytesArray.EMPTY, BytesArray.EMPTY, listener); - } + void getRegister(OperationPurpose purpose, String key, ActionListener listener); /** * Verify that the {@link OperationPurpose} is (somewhat) suitable for the name of the blob to which it applies: diff --git a/x-pack/plugin/searchable-snapshots/src/test/java/org/elasticsearch/xpack/searchablesnapshots/cache/common/TestUtils.java b/x-pack/plugin/searchable-snapshots/src/test/java/org/elasticsearch/xpack/searchablesnapshots/cache/common/TestUtils.java index 0f9c8502a0367..8125f8affdaf8 100644 --- a/x-pack/plugin/searchable-snapshots/src/test/java/org/elasticsearch/xpack/searchablesnapshots/cache/common/TestUtils.java +++ b/x-pack/plugin/searchable-snapshots/src/test/java/org/elasticsearch/xpack/searchablesnapshots/cache/common/TestUtils.java @@ -269,6 +269,11 @@ public void compareAndExchangeRegister( listener.onFailure(unsupportedException()); } + @Override + public void getRegister(OperationPurpose purpose, String key, ActionListener listener) { + listener.onFailure(unsupportedException()); + } + private UnsupportedOperationException unsupportedException() { assert false : "this operation is not supported and should have not be called"; return new UnsupportedOperationException("This operation is not supported");