[ https://issues.apache.org/jira/browse/CASSANDRA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jonathan Ellis reassigned CASSANDRA-1678: ----------------------------------------- Assignee: Gary Dusbabek Odd, I see the code trying to add the missing hosts in describeSchemaVersions: {code} results.put(DatabaseDescriptor.INITIAL_VERSION.toString(), missingHostNames); {code} But IMO the right fix is to avoid that entirely and do the simple thing instead: {code} /** * for each schema version present in the cluster, returns a list of nodes at that version. * hosts that do not respond will not be included. * the cluster is all on the same version if the size of the map is 1 and the * length of the list in that map value is the number of nodes in the cluster. */ {code} > describe_schema_versions does not list downed hosts > --------------------------------------------------- > > Key: CASSANDRA-1678 > URL: https://issues.apache.org/jira/browse/CASSANDRA-1678 > Project: Cassandra > Issue Type: Bug > Components: API > Affects Versions: 0.7 beta 2 > Reporter: Edward Capriolo > Assignee: Gary Dusbabek > Priority: Minor > > According to the description unreachable hosts should be listed. It does not > seem like they are. > {noformat} > map<string, list<string>> describe_schema_versions() > [java] key:c3f38ebc-e1c5-11df-95a0-e700f669bcfc > [java] 127.0.0.2 > [java] 127.0.0.3 > [java] 127.0.0.4 > [java] 127.0.0.1 > Address Status State Load Token > > > 105444142448428656124184491892431731479 > 127.0.0.3 Up Normal 56.53 KB > 43021486531749787992103274496183765897 > 127.0.0.1 Up Normal 56.24 KB > 49910048177093876350019363877113991186 > 127.0.0.5 Down Normal 52.49 KB > 64377498999076014343862177049497951437 > 127.0.0.2 Up Normal 65.27 KB > 84713069031498515281943177906254878023 > 127.0.0.4 Up Normal 55.95 KB > 105444142448428656124184491892431731479 > {noformat} > The code looks like this: > {noformat} > Cassandra.Client client = fcw.getClient(); > Map<String,List<String>> sv =client.describe_schema_versions(); > for (Map.Entry<String,List<String>> mapEntry: sv.entrySet()){ > System.out.println("key:"+mapEntry.getKey()); > for (String listForKey : mapEntry.getValue()){ > System.out.println("\t"+listForKey); > } > } > {noformat} -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.