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

New cache creation based on newly created configuration template over CLI requires server restart

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Obsolete
    • Icon: Major Major
    • None
    • None
    • CLI, Server
    • None
    • Hide

      1. Start JDG server in domain mode - ./domain.sh
      2. Start the ./ispn-cli.sh --connect and create new cache configuration and link a cache to it, e.g. 

      /profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/configurations=CONFIGURATIONS/replicated-cache-configuration=arev:add(mode=SYNC,start=EAGER)
/profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/configurations=CONFIGURATIONS/replicated-cache-configuration=arev/transaction=TRANSACTION:add()
/profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/configurations=CONFIGURATIONS/replicated-cache-configuration=arev/transaction=TRANSACTION:write-attribute(name=mode,value=NON_XA)
/profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/configurations=CONFIGURATIONS/replicated-cache-configuration=arev/transaction=TRANSACTION:write-attribute(name=locking,value=PESSIMISTIC)

/profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/configurations=CONFIGURATIONS/replicated-cache-configuration=arev/compatibility=COMPATIBILITY:add()
/profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/configurations=CONFIGURATIONS/replicated-cache-configuration=arev/compatibility=COMPATIBILITY:write-attribute(name=enabled,value=true)

/profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/replicated-cache=testCache:add(configuration=arev)

      3. Then run the following main class: 

      public class Test {
  public static void main(String[] args) throws IOException {
        RemoteCacheManager remoteCacheManager = new RemoteCacheManager(new   ConfigurationBuilder().addServer().host("localhost")
                .port(11222).build(), true);
        RemoteCache<String, String> remoteCache = remoteCacheManager.getCache("testCache");
        RemoteCache scriptCache = remoteCacheManager.getCache("___script_cache");

        try (InputStream in = HotRodRemoteCacheDomainIT.class.getClassLoader().getResourceAsStream("test.js")) {
            scriptCache.put("test.js", loadFileAsString(in));
        }

        Map<String, Object> parameters = new HashMap<>();
        parameters.put("key", "parameter");
        parameters.put("value", "value");

        int result = remoteCache.execute("test.js", parameters);

        assertEquals(1, result);
        assertEquals("value", remoteCache.get("parameter"));
    }
}

test.js

// mode=local,language=javascript,parameters=[key,value]
cache.put(key, value);

// Return the size of the cache
cache.size()

      This code will fail with the following assertion error:
      Exception in thread "main" java.lang.AssertionError: expected:<value> but was:<null>

      This happens because there is no key with name "parameter" in the cache. The key was placed into the cache as a byte (the compatibility configuration was ignored).

      4. If you will restart the jdg-server and will run the same main class, then it will pass.

      The same can be done by using the transactions (before restarting the server, the program will throw a NullPointerException as there is no TransactionManager available). After restart it will pass.

      Show
      1. Start JDG server in domain mode - ./domain.sh 2. Start the ./ispn-cli.sh --connect and create new cache configuration and link a cache to it, e.g. /profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/configurations=CONFIGURATIONS/replicated-cache-configuration=arev:add(mode=SYNC,start=EAGER) /profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/configurations=CONFIGURATIONS/replicated-cache-configuration=arev/transaction=TRANSACTION:add() /profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/configurations=CONFIGURATIONS/replicated-cache-configuration=arev/transaction=TRANSACTION:write-attribute(name=mode,value=NON_XA) /profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/configurations=CONFIGURATIONS/replicated-cache-configuration=arev/transaction=TRANSACTION:write-attribute(name=locking,value=PESSIMISTIC) /profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/configurations=CONFIGURATIONS/replicated-cache-configuration=arev/compatibility=COMPATIBILITY:add() /profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/configurations=CONFIGURATIONS/replicated-cache-configuration=arev/compatibility=COMPATIBILITY:write-attribute(name=enabled,value= true ) /profile=clustered/subsystem=datagrid-infinispan/cache-container=clustered/replicated-cache=testCache:add(configuration=arev) 3. Then run the following main class: public class Test { public static void main( String [] args) throws IOException { RemoteCacheManager remoteCacheManager = new RemoteCacheManager( new ConfigurationBuilder().addServer().host( "localhost" ) .port(11222).build(), true ); RemoteCache< String , String > remoteCache = remoteCacheManager.getCache( "testCache" ); RemoteCache scriptCache = remoteCacheManager.getCache( "___script_cache" ); try (InputStream in = HotRodRemoteCacheDomainIT. class. getClassLoader().getResourceAsStream( "test.js" )) { scriptCache.put( "test.js" , loadFileAsString(in)); } Map< String , Object > parameters = new HashMap<>(); parameters.put( "key" , "parameter" ); parameters.put( "value" , "value" ); int result = remoteCache.execute( "test.js" , parameters); assertEquals(1, result); assertEquals( "value" , remoteCache.get( "parameter" )); } } test.js // mode=local,language=javascript,parameters=[key,value] cache.put(key, value); // Return the size of the cache cache.size() This code will fail with the following assertion error: Exception in thread "main" java.lang.AssertionError: expected:<value> but was:<null> This happens because there is no key with name "parameter" in the cache. The key was placed into the cache as a byte (the compatibility configuration was ignored). 4. If you will restart the jdg-server and will run the same main class, then it will pass. The same can be done by using the transactions (before restarting the server, the program will throw a NullPointerException as there is no TransactionManager available). After restart it will pass.

      When adding new cache configuration template (with linked cache) or modifying the existing cache configuration template (e.g. enabling the compatibility mode or transaction) using CLI, then the cache configuration is not visible from the client.
      The changes take affect only after the server restart.
      I would expect the cache be accessible right after the CLI changes are done.

      You can find the steps for reproduction in according section.

      Note: if only cache is created using CLI based on the existing configuration template (which was available before server start), then everything works fine - the configuration is applied to the newly created cache.

              Unassigned Unassigned
              amanukya@redhat.com Anna Manukyan
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

                Created:
                Updated:
                Resolved: