From 2b1ed89ec33139ec5fded0d5411bdf85f2dd119b Mon Sep 17 00:00:00 2001 From: Glauber Costa Date: Mon, 21 Aug 2017 22:50:38 -0400 Subject: [PATCH] fix auto_compaction request strings Column family is not being passed, so the requests fail to reach the correct endpoint. Signed-off-by: Glauber Costa --- .../java/org/apache/cassandra/service/StorageService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/apache/cassandra/service/StorageService.java b/src/main/java/org/apache/cassandra/service/StorageService.java index 01af87f..ddc23f4 100644 --- a/src/main/java/org/apache/cassandra/service/StorageService.java +++ b/src/main/java/org/apache/cassandra/service/StorageService.java @@ -1381,7 +1381,7 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean, log("disableAutoCompaction(String ks, String... columnFamilies)"); MultivaluedMap queryParams = new MultivaluedHashMap(); APIClient.set_query_param(queryParams, "cf", APIClient.join(columnFamilies)); - client.delete("/storage_service/auto_compaction/", queryParams); + client.delete("/storage_service/auto_compaction/" + ks, queryParams); } @Override @@ -1390,7 +1390,7 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean, MultivaluedMap queryParams = new MultivaluedHashMap(); APIClient.set_query_param(queryParams, "cf", APIClient.join(columnFamilies)); try { - client.post("/storage_service/auto_compaction/", queryParams); + client.post("/storage_service/auto_compaction/" + ks, queryParams); } catch (RuntimeException e) { // FIXME should throw the right exception throw new IOException(e.getMessage());