andreacavalli/scylla-jmx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

StorageService: handle loadNewSStable and forceKeyspaceCleanup

Browse Source 
keyspace cleanup was changed from GET to POST and load sstable was
missing the keyspace name.

Signed-off-by: Amnon Heiman <amnon@cloudius-systems.com>
This commit is contained in:
Amnon Heiman 2015-10-11 13:45:59 +03:00 committed by Pekka Enberg
parent f05c6709dd
commit 3bf092c83b
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/org/apache/cassandra/service/StorageService.java
View File

@ -459,8 +459,7 @@ public class StorageService extends NotificationBroadcasterSupport
MultivaluedMap<String, String> queryParams = new MultivaluedMapImpl(); MultivaluedMap<String, String> queryParams = new MultivaluedMapImpl();
APIClient.set_query_param(queryParams, "cf", APIClient.set_query_param(queryParams, "cf",
APIClient.join(columnFamilies)); APIClient.join(columnFamilies));
return c.getIntValue( return c.postInt("/storage_service/keyspace_cleanup/" + keyspaceName,
"/storage_service/keyspace_compaction/" + keyspaceName,
queryParams); queryParams);
} }
@ -1044,7 +1043,7 @@ public class StorageService extends NotificationBroadcasterSupport
log(" loadNewSSTables(String ksName, String cfName)"); log(" loadNewSSTables(String ksName, String cfName)");
MultivaluedMap<String, String> queryParams = new MultivaluedMapImpl(); MultivaluedMap<String, String> queryParams = new MultivaluedMapImpl();
queryParams.add("cf", cfName); queryParams.add("cf", cfName);
c.post("/storage_service/sstables/", queryParams); c.post("/storage_service/sstables/" + ksName, queryParams);
} }
/** /**