cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jonathan Ellis (JIRA)" <j...@apache.org>
Subject [jira] Assigned: (CASSANDRA-1678) describe_schema_versions does not list downed hosts
Date Thu, 28 Oct 2010 18:30:21 GMT

     [ 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.


Mime
View raw message