cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jonathan Ellis (JIRA)" <>
Subject [jira] [Created] (CASSANDRA-5632) Cross-DC bandwidth-saving broken
Date Wed, 12 Jun 2013 23:37:19 GMT
Jonathan Ellis created CASSANDRA-5632:

             Summary: Cross-DC bandwidth-saving broken
                 Key: CASSANDRA-5632
             Project: Cassandra
          Issue Type: Bug
          Components: Core
    Affects Versions: 1.2.0
            Reporter: Jonathan Ellis
            Assignee: Jonathan Ellis
             Fix For: 1.2.6

We group messages by destination as follows to avoid sending multiple messages to a remote

        // Multimap that holds onto all the messages and addresses meant for a specific datacenter
        Map<String, Multimap<Message, InetAddress>> dcMessages

When we cleaned out the MessageProducer stuff for 2.0, this code

                    Multimap<Message, InetAddress> messages = dcMessages.get(dc);

turned into

                    Multimap<MessageOut, InetAddress> messages = dcMessages.get(dc);
                    messages.put(rm.createMessage(), destination);

Thus, we weren't actually grouping anything anymore -- each destination replica was stored
under a separate Message key, unlike under the old CachingMessageProducer.

This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see:

View raw message