Hazelcast localKeySet - PullRequest
       5

Hazelcast localKeySet

0 голосов
/ 05 июня 2018

Я работаю с Hazelcast версии 3.10.Я пытаюсь работать с картой localKeySet (), и происходит следующее:

  • Если я работаю без включения MapStore, localKeySet () работает правильно: в каждом локальном узле KeySet () возвращаетсокращенный набор ключей.

  • Если я добавлю MapStore в конфигурацию карты, localKeySet () будет
    работать неправильно: в каждом локальном узле localKeySet () возвращаетвсе ключи на карте.

Я настроил карту с помощью этой функции:

private MapConfig mapConfigurationAux (Config config, String name, int backupCount, boolean statisticsEnabled, int mapStoreDelay,
        MapStore implementationMapStore) {

        MapConfig mapConfig = config.getMapConfig (name);
        mapConfig.setBackupCount(backupCount);
        mapConfig.setInMemoryFormat(InMemoryFormat.OBJECT);
        mapConfig.setStatisticsEnabled(statisticsEnabled);

        if (implementationMapStore! = null) {
            MapStoreConfig mapStoreConfig = new MapStoreConfig();
            mapStoreConfig.setEnabled(true);
            mapStoreConfig.setImplementation(implementationMapStore);
            mapStoreConfig.setWriteDelaySeconds(mapStoreDelay);
            mapStoreConfig.setWriteBatchSize(100);
            mapStoreConfig.setInitialLoadMode(InitialLoadMode.LAZY);
            mapConfig.setMapStoreConfig(mapStoreConfig);
        }
        return mapConfig;
    }

Что я могу делать не так?

1 Ответ

0 голосов
/ 13 июня 2018

Я обнаружил проблему Как и ожидалось, у меня была проблема с настройкой Hazelcast.В интерфейсе, который установил NetWorkConfig, он устанавливал 127.0.0.1 во всех экземплярах кластера.

NetworkConfig network = cfg.getNetworkConfig();
network.setPort(port).setPortAutoIncrement(true);
network.setPublicAddress(publicAddress);
network.getInterfaces().addInterface("127.0.0.1").setEnabled(true);
...