[
https://issues.apache.org/jira/browse/IGNITE-6537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tommyjarvis updated IGNITE-6537:
--------------------------------
Description:
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);
===========================================
config cache:
CacheConfiguration<Integer, String> cacheCfg = new
CacheConfiguration<>(CACHE_NAME);
cacheCfg.setExpiryPolicyFactory(CreatedExpiryPolicy.factoryOf(new
Duration(TimeUnit.MINUTES, 2)));
cacheCfg.setCacheMode(CacheMode.REPLICATED);
cacheCfg.setBackups(1);
cacheCfg.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);
IgniteCache cache = ignite.getOrCreateCache(cacheCfg);
==========================================
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
was:
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
> 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);
> ===========================================
> config cache:
> CacheConfiguration<Integer, String> cacheCfg = new
> CacheConfiguration<>(CACHE_NAME);
> cacheCfg.setExpiryPolicyFactory(CreatedExpiryPolicy.factoryOf(new
> Duration(TimeUnit.MINUTES, 2)));
> cacheCfg.setCacheMode(CacheMode.REPLICATED);
> cacheCfg.setBackups(1);
> cacheCfg.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);
>
> IgniteCache cache = ignite.getOrCreateCache(cacheCfg);
> ==========================================
> 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)
