Uploaded image for project: 'Infinispan'
  1. Infinispan
  2. ISPN-3293

Putting entries with memcached is ignoring the queue-flush-interval parameter

    XMLWordPrintable

Details

    • Bug
    • Resolution: Obsolete
    • Major
    • 9.0.0.Alpha1
    • None
    • Server
    • None

    Description

      I have a cluster of 2 nodes with the following configuration:

      <replicated-cache name="memcachedCache"
          start="EAGER"
          mode="ASYNC"
          batching="false"                    
          queue-size="1000"
          queue-flush-interval="15000">
      </replicated-cache>
      

      The following code (MemcachedHelper is a memcached client)

      mc1 = new MemcachedHelper(server1.getMemcachedEndpoint().getInetAddress().getHostName(), server1.getMemcachedEndpoint().getPort());
      mc2 = new MemcachedHelper(server2.getMemcachedEndpoint().getInetAddress().getHostName(), server2.getMemcachedEndpoint().getPort());
      mc1.set("key1", "value1");
      assertTrue(null != mc1.get("key1"));
      assertTrue(null == mc2.get("key1"));
      

      fails on the 2nd assert, because the entry is retrieved.

      According to logs (attached), the replication queue is correctly flushed after 15 seconds with 1 element (and happens after the gets).

      Works correctly with hotrod (entry is replicated only after the flush happens).

      Attachments

        1. server1.log
          809 kB
        2. server2.log
          864 kB

        Issue Links

          Activity

            People

              Unassigned Unassigned
              jmarkos Jakub Markos (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: