ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "tommyjarvis (JIRA)" <j...@apache.org>
Subject [jira] [Created] (IGNITE-6537) Transactions bug
Date Mon, 02 Oct 2017 09:08:01 GMT
tommyjarvis created IGNITE-6537:
-----------------------------------

             Summary: Transactions bug 
                 Key: IGNITE-6537
                 URL: https://issues.apache.org/jira/browse/IGNITE-6537
             Project: Ignite
          Issue Type: Bug
          Components: examples
    Affects Versions: 2.2
         Environment: general
            Reporter: tommyjarvis


Code:
get ignite:
==============================
   org.apache.ignite.configuration.IgniteConfiguration cfg = new org.apache.ignite.configuration.IgniteConfiguration();

        TcpDiscoverySpi spi = new TcpDiscoverySpi();
        spi.setLocalPort(48501);
        spi.setLocalPortRange(20);
        TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
        ipFinder.setAddresses(serverList);
        spi.setIpFinder(ipFinder);

        TcpCommunicationSpi commSpi = new TcpCommunicationSpi();
        commSpi.setSlowClientQueueLimit(1000);
        commSpi.setLocalPort(48101);
        cfg.setClientMode(true);
        cfg.setDiscoverySpi(spi);
        cfg.setCommunicationSpi(commSpi);
        cfg.setPeerClassLoadingEnabled(true);
        PersistentStoreConfiguration persistentStoreConfiguration = new PersistentStoreConfiguration();
        cfg.setPersistentStoreConfiguration(persistentStoreConfiguration); 
        ignite = Ignition.start(cfg);
==========================================
transaction like this:

   Thread t = new Thread(() -> {
                try (Transaction tx = ignite.transactions().txStart()) {
                    for (int i = 0; i < 1000; i++) {
                        cache.put(i, i);
                    }
                    tx.commit();
                }

            });
            t.start();
            //
            int lastSize = 0;
            while (true) {
                int size = cache.size();
                //            int size = cache2.localSize();
                size = cache.query(new ScanQuery<>()).getAll().size();
                if (size != lastSize) {
                    System.out.println(size);
                    lastSize = size;
                }
                System.out.println("##################################" + size);
            }

i thought  only print ###0  and ###1000
but after i run print like this:
163
##################################163
515
##################################515
1000
##################################1000
##################################1000






--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message