Ehcache disk store unclean shutdown

Question

I'm using a cache with disk store persistence. On subsequent reruns of the app I'm getting the following error:

net.sf.ehcache.store.DiskStore deleteIndexIfCorrupt
WARNING: The index for data file MyCache.data is out of date,
probably due to an unclean shutdown. Deleting index file MYCache.index

Is there any way to fix that apart from explicitly calling net.sf.ehcache.CacheManager.shutdown() somewhere in the app?

Cache configuration:

<ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:noNamespaceSchemaLocation="ehcache.xsd"
             updateCheck="true" monitoring="autodetect">

    <diskStore path="C:\work"/>

    <cacheManagerEventListenerFactory class="" properties=""/>

    <cacheManagerPeerProviderFactory
            class="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory"
            properties="peerDiscovery=automatic,
                        multicastGroupAddress=230.0.0.1,
                        multicastGroupPort=4446, timeToLive=1"
            propertySeparator=","
            />

    <cacheManagerPeerListenerFactory
            class="net.sf.ehcache.distribution.RMICacheManagerPeerListenerFactory"/>

    <defaultCache
            maxElementsInMemory="1"
            eternal="false"
            timeToIdleSeconds="0"
            timeToLiveSeconds="86400"
            overflowToDisk="true"
            diskSpoolBufferSizeMB="1"
            maxElementsOnDisk="10000"
            diskPersistent="true"
            diskExpiryThreadIntervalSeconds="120"
            memoryStoreEvictionPolicy="LFU"
            />

</ehcache>

Code to replicate the issue:

import java.util.ArrayList;
import java.util.List;

import net.sf.ehcache.Cache;
import net.sf.ehcache.CacheManager;
import net.sf.ehcache.Element;

public class CacheTest {
    static CacheManager manager = new CacheManager(CacheTest.class
            .getResource("ehcache.xml"));
    static Cache cache;

    public static void main(String[] args) {

        // Get a default instance
        manager.addCache("test");
        cache = manager.getCache("test");

        // Generate some junk so that the
        // cache properly flushes to disk
        // as cache.flush() is not working
        List<String> t = new ArrayList<String>();
        for (int i = 0; i < 1000; i++)
            t.add(null);
        // Oddly enough fewer elements
        // do not persist to disk or give
        // an error
        for (int i = 0; i < 100000; i++) {
            cache.put(new Element(i, t));
        }
        cache.flush();

        if (cache.get("key1") == null) {
            System.out.println("key1 not found in cache!");
            cache.put(new Element("key1", "value1"));
        }

        System.out.println(cache.get("key1"));
    }
}

score 13 · Accepted Answer · edited Dec 10 '12 at 07:33

Try setting the system property: net.sf.ehcache.enableShutdownHook=true

So, either you can add the following line in the beginning of your program: System.setProperty("net.sf.ehcache.enableShutdownHook","true");

Or, from the command line to pass the property: java -Dnet.sf.ehcache.enableShutdownHook=true ...

Note, the ehcache website does mention some caution when using this shutdown hook: Shutting Down Ehcache

When a shutdown hook will run, and when it will not

The shutdown hook runs when:

a program exists normally. e.g. System.exit() is called, or the last non-daemon thread exits

the Virtual Machine is terminated. e.g. CTRL-C. This corresponds to kill -SIGTERM pid or kill -15 pid on Unix systems.

The shutdown hook will not run when:

the Virtual Machine aborts

A SIGKILL signal is sent to the Virtual Machine process on Unix systems. e.g. kill -SIGKILL pid or kill -9 pid

A TerminateProcess call is sent to the process on Windows systems.

Hope it works :)

score 2 · Answer 2 · edited Jun 20 '20 at 09:12

2

How are you stopping your application?

From looking at the Ehcache code, it registers a JVM shutdown hook Runtime.getRuntime().addShutdownHook that closes the cache on JVM exit. If the JVM is killed, or crashes, the shutdown hook will not be called.

Update RE your comment:

Here is the comment from the DiskStore dispose method:

Shuts down the disk store in preparation for cache shutdown

If a VM crash happens, the shutdown hook will not run. The data file and the index file will be out of synchronisation. At initialisation we always delete the index file after we have read the elements, so that it has a zero length. On a dirty restart, it still will have and the data file will automatically be deleted, thus preserving safety.

So, if your recreating the Cache in a different Unit test. Since the shutdownHook wouldn't have run, the index file will be 0. Ehcache thinks the index is corrupt. I would shutdown the Cache using JUnit's @After annotation in each of your unit tests. Or, share the Cache across all tests, but I'm guessing this would not give you isolated tests.

edited Jun 20 '20 at 09:12

Community

1
1

answered Mar 03 '10 at 17:44

Steve K

19,408
6
52
50

I'm running it as part of a Junit4 test. The error shows on a subsequent rerun of the test. I can provide a code sample to replicate if it helps. – Tomasz Mar 04 '10 at 10:39
nope, still getting the same error, even when running from command line in a runnable jar. – Tomasz Mar 05 '10 at 13:38
I guess some sample code might be good. You might also try to run only a single test, and check the size of the index file. Based on the comment from ehcache's code, it should be something other than 0. – Steve K Mar 05 '10 at 13:48
Added some code to replicate the issue. The .data file gets created properly but the .index stays at 0. – Tomasz Mar 05 '10 at 16:40

score 1 · Answer 3 · edited May 23 '17 at 12:17

For those of us using Ehcache with Spring 3.1+ and java config, you have to use:

@Bean(destroyMethod = "shutdown")
public net.sf.ehcache.CacheManager ehCacheManager() { .. }

and (assuming you're also using a non-web Spring ApplicationContext, enable the shutdown hook there to cause the bean to be destroyed gracefully:

context = new AnnotationConfigApplicationContext(AppConfig.class);
((AbstractApplicationContext) context).registerShutdownHook();

see this for more information.

Ehcache disk store unclean shutdown

3 Answers3

Linked