| commit | 1a70ae50651a738cfccf7b2e78c0e4ec55868f76 | [log] [tgz] |
|---|---|---|
| author | JiangHaiting <jianghaiting@apache.org> | Mon Dec 20 09:17:04 2021 +0800 |
| committer | GitHub <noreply@github.com> | Mon Dec 20 09:17:04 2021 +0800 |
| tree | a4e9d62724716f6c1ff899a689dd4d898b92084f | |
| parent | 47a94b54d1838d3dcce13c4dc4fe36e7c1ef1ed0 [diff] |
Avoid raw use of parameterized class 'MessagePassingQueue' (#13386)
diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java index 058d62b..5d78282 100644 --- a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java +++ b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java
@@ -143,7 +143,7 @@ return op.getFuture(); } - private void enqueue(MessagePassingQueue queue, MetadataOp op) { + private void enqueue(MessagePassingQueue<MetadataOp> queue, MetadataOp op) { if (enabled) { if (!queue.offer(op)) { // Execute individually if we're failing to enqueue