ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yann BLAZART <yann.blaz...@externe.bnpparibas.com>
Subject RE: Ignite "bugs" ?
Date Thu, 14 Jan 2016 08:35:01 GMT
Hello. I'm not using config file I'm using java code to configure : 


   @Produces
    @ApplicationScoped
    public Ignite produceInstance() {
        LOG.info("** Prepare Ignite ");

        IgniteConfiguration config = new IgniteConfiguration();
        config.setClientMode(false);
        config.setLifecycleBeans(e -> igniteEventRaiser.fire(e));

        CacheConfiguration glblCacheConfig=new CacheConfiguration();
        glblCacheConfig.setStartSize(100*1024*1024);

        CacheConfiguration cacheConfigFeedsFlow = getCacheConfiguration(GridService.FEEDS_FLOW_MAP_KEY,
feedsFlowMapStore);

        CacheConfiguration cacheConfigFeedsFlowRaw=getCacheConfiguration(GridService.FEEDS_FLOW_RAW_MAP_KEY,feedsFlowRawMapStore);

        CacheConfiguration cacheConfigFeedsFlowSource=getCacheConfiguration(GridService.FEEDS_FLOW_SOURCE_MAP_KEY,feedsFlowSourceMapStore);


        config.setCacheConfiguration(glblCacheConfig,cacheConfigFeedsFlow,cacheConfigFeedsFlowRaw,cacheConfigFeedsFlowSource);

        TcpDiscoverySpi discoverySpi=new TcpDiscoverySpi();
        TcpDiscoveryJdbcIpFinder ipFinder=new TcpDiscoveryJdbcIpFinder();
        ipFinder.setDataSource(dataSource);
        discoverySpi.setIpFinder(ipFinder);
        config.setDiscoverySpi(discoverySpi);

        TransactionConfiguration txConfig=new TransactionConfiguration();
        txConfig.setTxManagerFactory(()->transactionManager);
        config.setTransactionConfiguration(txConfig);

        Hashtable<Object,Object> backup = new Hashtable<>();
        Hashtable<Object,Object> hashtableFromSystemProperties = System.getProperties();
        Enumeration<Object> keys = hashtableFromSystemProperties.keys();
        while ( keys.hasMoreElements() ) {
            Object key =keys.nextElement();
            if ( !  (hashtableFromSystemProperties.get(key) instanceof  String) ) {
                LOG.info("*** Prepare ignite : remove {} from System.properties",key);
                backup.put(key,hashtableFromSystemProperties.get(key));
                hashtableFromSystemProperties.remove(key);
            }
        }
        Ignite ignite = Ignition.start(config);

        hashtableFromSystemProperties.putAll(backup);
        LOG.info("*** Prepare ignite : restore key into from System.properties");
        return ignite;
    }



@NotNull
    private CacheConfiguration getCacheConfiguration(String name, GenericFeedsFlowJPACacheStore<?>
cacheStore) {
        CacheConfiguration config=new CacheConfiguration(name);
        config.setCacheStoreFactory(new FixedCacheStoreFactory(cacheStore));
        config.setWriteThrough(true);
        config.setReadThrough(true);
        config.setCacheMode(CacheMode.PARTITIONED);
        config.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);
        return config;
    }


-----Original Message-----
From: vkulichenko [mailto:valentin.kulichenko@gmail.com] 
Sent: jeudi 14 janvier 2016 04:15
To: user@ignite.apache.org
Subject: RE: Ignite "bugs" ?

Yann,

It sounds like you have some misconfiguration for discovery. Can you also provide your configuration
file?

-Val



--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Ignite-bugs-tp2534p2550.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.


This message and any attachments (the "message") is
intended solely for the intended addressees and is confidential. 
If you receive this message in error,or are not the intended recipient(s), 
please delete it and any copies from your systems and immediately notify
the sender. Any unauthorized view, use that does not comply with its purpose, 
dissemination or disclosure, either whole or partial, is prohibited. Since the internet 
cannot guarantee the integrity of this message which may not be reliable, BNP PARIBAS 
(and its subsidiaries) shall not be liable for the message if modified, changed or falsified.

Do not print this message unless it is necessary,consider the environment.

----------------------------------------------------------------------------------------------------------------------------------

Ce message et toutes les pieces jointes (ci-apres le "message") 
sont etablis a l'intention exclusive de ses destinataires et sont confidentiels.
Si vous recevez ce message par erreur ou s'il ne vous est pas destine,
merci de le detruire ainsi que toute copie de votre systeme et d'en avertir
immediatement l'expediteur. Toute lecture non autorisee, toute utilisation de 
ce message qui n'est pas conforme a sa destination, toute diffusion ou toute 
publication, totale ou partielle, est interdite. L'Internet ne permettant pas d'assurer
l'integrite de ce message electronique susceptible d'alteration, BNP Paribas 
(et ses filiales) decline(nt) toute responsabilite au titre de ce message dans l'hypothese
ou il aurait ete modifie, deforme ou falsifie. 
N'imprimez ce message que si necessaire, pensez a l'environnement.


Mime
View raw message