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

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

XMLWordPrintable

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

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

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

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

              Created:
              Updated:
              Resolved: