Ignite Remote Server Thread Not exit, причина нехватки памяти, наконец

Когда я запускаю задание удаленных вычислений, вызываю () или affinityCall (). Удаленный сервер создаст 6 потоков, и эти потоки никогда не завершатся. Так же, как VisualVM показано ниже:

просмотреть снимок VisualVM

имя потока от «utility- # 153% null%» до «marshaller-cache- # 14i% null%» никогда не будет завершено. Если клиент запускается снова и снова, количество потоков на серверном узле будет быстро увеличиваться. В результате узлу сервера не хватает памяти.

Как я могу закрыть этот поток, когда клиент закрыт. Возможно, я не запускаю клиент в текущем режиме.

Код клиента

String cacheKey = "jobIds";
String cname = "myCacheName";
ClusterGroup rmts = getIgnite().cluster().forRemotes();
IgniteCache<String, List<String>> cache = getIgnite().getOrCreateCache(cname);
List<String> jobList = cache.get(cacheKey);
Collection<String> res = ignite.compute(rmts).apply(
        new IgniteClosure<String, String>() {
            @Override
            public String apply(String word) {
                return word;
            }
        },
        jobList
    );
getIgnite().close();
System.out.println("ignite Closed");

if (res == null) {
    System.out.println("Error: Result is null");
    return;
}

res.forEach(s -> {
    System.out.println(s);
});
System.out.println("Finished!");

getIgnite (), получите экземпляр Ignite.

public static Ignite getIgnite() {
    if (ignite == null) {
        System.out.println("RETURN INSTANCE ..........");
        Ignition.setClientMode(true);
        ignite = Ignition.start(confCache);
        ignite.configuration().setDeploymentMode(DeploymentMode.CONTINUOUS);
    }

    return ignite;
}

Конфигурация сервера:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="
        http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd">
        <!--
        Alter configuration below as needed.
        -->
        <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
            <property name="peerClassLoadingEnabled" value="true"/>
            <property name="peerClassLoadingMissedResourcesCacheSize" value="0"/>
            <property name="publicThreadPoolSize" value="64"/>

            <property name="discoverySpi">
                <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
                    <property name="ipFinder">
                        <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
                            <property name="addresses">
                                <list>
                                    <value>172.22.1.72:47500..47509</value>
                                    <value>172.22.1.100:47500..47509</value>
                                </list>
                            </property>
                        </bean>
                    </property>
                </bean>
            </property>

            <property name="cacheConfiguration">
                <bean class="org.apache.ignite.configuration.CacheConfiguration">
                    <property name="cacheMode" value="PARTITIONED"/>
                    <property name="memoryMode" value="ONHEAP_TIERED"/>
                    <property name="backups" value="0"/>
                    <property name="offHeapMaxMemory" value="0"/>
                    <property name="swapEnabled" value="false"/>
                </bean>
            </property>
        </bean>
</beans>