You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@ignite.apache.org by kotamrajuyashasvi <ko...@gmail.com> on 2018/06/12 13:24:03 UTC
Getting NullPointerException during commit into cassandra, after
reconnecting to ignite server
Hi
I'm working on an ignite project with cassandra as persistent storage.
Initially an ignite client connects to a ignite server. After connecting if
ignite server
is restarted, the client also reconnects to the server. But after
reconnecting during
committing data into cassandra I'm running into NullPointerException for
some of the runs/attempts randomly.
caused by: java.lang.NullPointerException
at
org.apache.ignite.cache.store.cassandra.persistence.PojoField.getValueFromObject(PojoField.java:167)
at
org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.bindValues(PersistenceController.java:450)
at
org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.bindKeyValue(PersistenceController.java:202)
at
org.apache.ignite.cache.store.cassandra.session.transaction.WriteMutation.bindStatement(WriteMutation.java:58)
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:499)
I'm observing the issue randomly and after going through the source code
there is a suspicion that its a java serialization issue in ignite cassandra
module
In org.apache.ignite.cache.store.cassandra.persistence.PojoField.java, there
is a PojoFieldAccessor instance variable which is transient type, so it will
not be part of serialization and if PojoField object is serialized and then
deserialized it would have PojoFieldAccessor as null. And in the Exception
we are seeing the same, NullPointerException when getValue(..) is called on
null PojoFieldAccessor in PojoField.getValueFromObject() method . So when
ever PojoField object is serialized and then deserialized we might be
observing the issue.
Below are steps for reproducing the issue
1. start the ignite server.
2. start the reproducer client and immediately after it starts to sleep,
kill and restart the ignite server.
we can observe that client reconnects to the server.
But during commit we sometimes observe NullPointerException . We can try
attempting steps 1 and 2 till we encounter the issue.
Following is a sample reproducer:
****************** DemoProgram *************
package com.IgniteDemo;
import java.util.*;
import javax.cache.Cache.Entry;
import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.IgniteException;
import org.apache.ignite.Ignition;
import org.apache.ignite.cache.query.QueryCursor;
import org.apache.ignite.cache.query.SqlFieldsQuery;
import org.apache.ignite.cache.query.SqlQuery;
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;
public class DemoMain {
public static void main(String[] args){
String ConfigPath = "default-config.xml";
Ignite ignite = Ignition.start(ConfigPath);
//sleep for 30 seconds after ignite client is started and connected to one
ignite server.
//During this time quickly restart the ignite server to which the client is
connecting to.
System.out.println("sleeping..");
Thread.sleep(30000);
IgniteCache<PersonPK, Person> cache = ignite.cache("Person");
Transaction tx =
ignite.transactions().txStart(TransactionConcurrency.PESSIMISTIC,
TransactionIsolation.REPEATABLE_READ, 60000, 0);
long dob = 771465600000L;
Person p1 = new Person(1,"yash",22,"124345","addr",new Date(dob));
cache.put(p1.getPK(),p1);
System.out.println("cache put successful");
System.out.println("committing..");
tx.commit();
System.out.println("cache size "+ cache.size());
}
*** OUTPUT ***
[18:13:00] Topology snapshot [ver=2, servers=1, clients=1, CPUs=4,
heap=2.8GB]
sleeping..
[18:13:04] Failed to connect to any address from IP finder (will retry to
join topology every 2 secs): [/127.0.0.1:47500]
[18:13:05,619][SEVERE][tcp-client-disco-sock-writer-#2][TcpDiscoverySpi]
Failed to send message: TcpDiscoveryClientMetricsUpdateMessage
[super=TcpDiscoveryAbstractMessage [sndNodeId=null,
id=9374504f361-228d774d-1de9-47ff-9ad7-cb69400bd890, verifierNodeId=null,
topVer=0, pendingIdx=0, failedNodes=null, isClient=true]]
java.net.SocketException: Socket is closed
at java.net.Socket.getSendBufferSize(Unknown Source)
at
org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi.socketStream(TcpDiscoverySpi.java:1358)
at
org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi.writeToSocket(TcpDiscoverySpi.java:1470)
at
org.apache.ignite.spi.discovery.tcp.ClientImpl$SocketWriter.body(ClientImpl.java:1240)
at org.apache.ignite.spi.IgniteSpiThread.run(IgniteSpiThread.java:62)
[18:13:09] New version is available at ignite.apache.org: 2.4.0
[18:13:10,727][SEVERE][tcp-client-disco-reconnector-#5][TcpDiscoverySpi]
Failed to reconnect to cluster (consider increasing 'networkTimeout'
configuration property) [networkTimeout=5000]
[18:13:19] Client node was reconnected after it was already considered
failed by the server topology (this could happen after all servers restarted
or due to a long network outage between the client and servers). All
continuous queries and remote event listeners created by this client will be
unsubscribed, consider listening to EVT_CLIENT_NODE_RECONNECTED event to
restore them.
[18:13:20] Topology snapshot [ver=2, servers=1, clients=1, CPUs=4,
heap=2.8GB]
cache put successful
committing..
[18:37:55,656][SEVERE][sys-stripe-1-#2][CassandraCacheStore] Failed to apply
1 mutations performed withing Ignite transaction into Cassandra
class org.apache.ignite.IgniteException: Failed to apply 1 mutations
performed withing Ignite transaction into Cassandra
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:534)
at
org.apache.ignite.cache.store.cassandra.CassandraCacheStore.sessionEnd(CassandraCacheStore.java:172)
at
org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.sessionEnd(GridCacheStoreManagerAdapter.java:790)
at
org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter.sessionEnd(IgniteTxAdapter.java:1228)
at
org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter.batchStoreCommit(IgniteTxAdapter.java:1410)
at
org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter.userCommit(IgniteTxLocalAdapter.java:502)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.localFinish(GridNearTxLocal.java:3078)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture.finish(GridNearTxFinishFuture.java:418)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$16.apply(GridNearTxLocal.java:3229)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$16.apply(GridNearTxLocal.java:3223)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:383)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.unblock(GridFutureAdapter.java:347)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.unblockAll(GridFutureAdapter.java:335)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:495)
at
org.apache.ignite.internal.processors.cache.GridCacheCompoundFuture.onDone(GridCacheCompoundFuture.java:56)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:474)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearPessimisticTxPrepareFuture.onDone(GridNearPessimisticTxPrepareFuture.java:410)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearPessimisticTxPrepareFuture.onDone(GridNearPessimisticTxPrepareFuture.java:58)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:451)
at
org.apache.ignite.internal.util.future.GridCompoundFuture.checkComplete(GridCompoundFuture.java:285)
at
org.apache.ignite.internal.util.future.GridCompoundFuture.apply(GridCompoundFuture.java:144)
at
org.apache.ignite.internal.util.future.GridCompoundFuture.apply(GridCompoundFuture.java:45)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:383)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.unblock(GridFutureAdapter.java:347)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.unblockAll(GridFutureAdapter.java:335)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:495)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:474)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:451)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearPessimisticTxPrepareFuture$MiniFuture.onResult(GridNearPessimisticTxPrepareFuture.java:477)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearPessimisticTxPrepareFuture.onResult(GridNearPessimisticTxPrepareFuture.java:106)
at
org.apache.ignite.internal.processors.cache.transactions.IgniteTxHandler.processNearTxPrepareResponse(IgniteTxHandler.java:657)
at
org.apache.ignite.internal.processors.cache.transactions.IgniteTxHandler.access$100(IgniteTxHandler.java:97)
at
org.apache.ignite.internal.processors.cache.transactions.IgniteTxHandler$2.apply(IgniteTxHandler.java:183)
at
org.apache.ignite.internal.processors.cache.transactions.IgniteTxHandler$2.apply(IgniteTxHandler.java:181)
at
org.apache.ignite.internal.processors.cache.GridCacheIoManager.processMessage(GridCacheIoManager.java:1060)
at
org.apache.ignite.internal.processors.cache.GridCacheIoManager.onMessage0(GridCacheIoManager.java:579)
at
org.apache.ignite.internal.processors.cache.GridCacheIoManager.handleMessage(GridCacheIoManager.java:378)
at
org.apache.ignite.internal.processors.cache.GridCacheIoManager.handleMessage(GridCacheIoManager.java:304)
at
org.apache.ignite.internal.processors.cache.GridCacheIoManager.access$100(GridCacheIoManager.java:99)
at
org.apache.ignite.internal.processors.cache.GridCacheIoManager$1.onMessage(GridCacheIoManager.java:293)
at
org.apache.ignite.internal.managers.communication.GridIoManager.invokeListener(GridIoManager.java:1555)
at
org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:1183)
at
org.apache.ignite.internal.managers.communication.GridIoManager.access$4200(GridIoManager.java:126)
at
org.apache.ignite.internal.managers.communication.GridIoManager$9.run(GridIoManager.java:1090)
at
org.apache.ignite.internal.util.StripedExecutor$Stripe.run(StripedExecutor.java:505)
at java.lang.Thread.run(Unknown Source)
Caused by: java.lang.NullPointerException
at
org.apache.ignite.cache.store.cassandra.persistence.PojoField.getValueFromObject(PojoField.java:167)
at
org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.bindValues(PersistenceController.java:450)
at
org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.bindKeyValue(PersistenceController.java:202)
at
org.apache.ignite.cache.store.cassandra.session.transaction.WriteMutation.bindStatement(WriteMutation.java:58)
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:499)
... 45 more
*********** Person.java *********************
package com.IgniteDemo;
import java.util.Date;
import org.apache.ignite.cache.query.annotations.QuerySqlField;
public class Person {
@QuerySqlField(index = false)
private int person_no;
@QuerySqlField(index = false)
private String name;
@QuerySqlField(index = false)
private Integer age=null;
@QuerySqlField(index = false)
private String phno;
@QuerySqlField(index = false)
private String address;
@QuerySqlField(index = false)
public String tid="t1";
@QuerySqlField(index = false)
public Date dob;
public Date getDob() {
return dob;
}
public void setDob(Date dob) {
this.dob = dob;
}
public Person(){
}
public int getPerson_no() {
return person_no;
}
public void setPerson_no(int person_no) {
this.person_no = person_no;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Integer getAge() {
return age;
}
public void setAge(Integer age) {
this.age = age;
}
public String getPhno() {
return phno;
}
public void setPhno(String phno) {
this.phno = phno;
}
public String getAddress() {
return address;
}
public void setAddress(String address) {
this.address = address;
}
public PersonPK getPK(){
return new PersonPK(person_no,phno);
}
public Person(int person_no, String name, Integer age, String phno,
String
address, Date dob) {
this.person_no = person_no;
this.name = name;
this.age = age;
this.phno = phno;
this.address = address;
this.dob = dob;
}
}
*******************************************************************************
************* PersonPK.java ***************
package com.IgniteDemo;
import java.util.Arrays;
public class PersonPK {
private String phno;
private int person_no;
public PersonPK(){
}
public PersonPK(int person_no,String phno){
this.person_no = person_no;
this.phno = phno;
}
public int getPerson_no() {
return person_no;
}
public void setPerson_no(int person_no) {
this.person_no = person_no;
}
public String getPhno() {
return phno;
}
public void setPhno(String phno) {
this.phno = phno;
}
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + person_no;
result = prime * result + ((phno == null) ? 0 :
phno.hashCode());
return result;
}
@Override
public boolean equals(Object obj) {
if (this == obj)
return true;
if (obj == null)
return false;
if (getClass() != obj.getClass())
return false;
PersonPK other = (PersonPK) obj;
if (person_no != other.person_no)
return false;
if (phno == null) {
if (other.phno != null)
return false;
} else if (!phno.equals(other.phno))
return false;
return true;
}
@Override
public String toString() {
return "PersonPK [phno=" + phno + ", person_no=" + person_no
+ "]";
}
}
***********************************************************************************
**************** default-config.xml ****************************
<?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">
<import resource="./connection-settings.xml" />
<bean id="cache_persistence_settings"
class="org.apache.ignite.cache.store.cassandra.persistence.KeyValuePersistenceSettings">
<constructor-arg type="org.springframework.core.io.Resource"
value="file:C:\Users\persistence-settings.xml" />
</bean>
<bean id="grid.cfg"
class="org.apache.ignite.configuration.IgniteConfiguration">
<property name="clientMode" value="true"/>
<property name="cacheConfiguration">
<list>
<bean
class="org.apache.ignite.configuration.CacheConfiguration">
<property name="name" value="Person"/>
<property name="readThrough" value="true"/>
<property name="writeThrough" value="true"/>
<property name="cacheMode" value="PARTITIONED"/>
<property name="indexedTypes">
<list>
<value>com.IgniteDemo.PersonPK</value>
<value>com.IgniteDemo.Person</value>
</list>
</property>
<property name="cacheStoreFactory">
<bean
class="org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory">
<property name="dataSourceBean"
value="cassandraRegularDataSource"/>
<property name="persistenceSettingsBean"
value="cache_persistence_settings"/>
</bean>
</property>
<property name="queryEntities">
<list>
<bean
class="org.apache.ignite.cache.QueryEntity">
<property name="keyType"
value="com.IgniteDemo.PersonPK"/>
<property name="valueType"
value="com.IgniteDemo.Person"/>
</bean>
</list>
</property>
<property name="atomicityMode"
value="TRANSACTIONAL"/>
</bean>
</list>
</property>
<property name="peerClassLoadingEnabled" value="true"/>
<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>127.0.0.1:47500..47509</value>
</list>
</property>
</bean>
</property>
</bean>
</property>
</bean>
</beans>
*************************************************************************************
*********** persistence-settings.xml ***********
<persistence keyspace="testkeyspace" table="person">
<keyPersistence class="com.IgniteDemo.PersonPK" strategy="POJO" />
<valuePersistence class="com.IgniteDemo.Person" strategy="POJO" />
</persistence>
***************************************************
********** connection-settings.xml *************************************
<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">
<bean id="loadBalancingPolicy"
class="com.datastax.driver.core.policies.TokenAwarePolicy">
<constructor-arg
type="com.datastax.driver.core.policies.LoadBalancingPolicy">
<bean
class="com.datastax.driver.core.policies.RoundRobinPolicy"/>
</constructor-arg>
</bean>
<bean id="cassandraRegularDataSource"
class="org.apache.ignite.cache.store.cassandra.datasource.DataSource">
<property name="readConsistency" value="QUORUM"/>
<property name="writeConsistency" value="QUORUM"/>
<property name="loadBalancingPolicy" ref="loadBalancingPolicy"/>
<property name="user" value="cassandra"/>
<property name="password" value="cassandra"/>
<property name="contactPoints">
<list>
<value>10.1.2.3</value>
</list>
</property>
</bean>
</beans>
*********************************************************
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
Re: Getting NullPointerException during commit into cassandra, after
reconnecting to ignite server
Posted by Ilya Kasnacheev <il...@gmail.com>.
Hello!
As far as my understanding goes, the workaround is as follows:
- Declare all cassandra-backed caches on client nodes along with their
cache store.
- clientReconnectDisabled true.
You can also track https://issues.apache.org/jira/browse/IGNITE-8788
Regards,
--
Ilya Kasnacheev
ср, 16 сент. 2020 г. в 02:59, xmw45688 <xw...@procurant.com>:
> I got this exception for ignite 2.8.0. When the note restarted and the
> data
> is inserted into the cache and Cassandra store. Please note
> 1) my setup is that Native Persistence is enabled. just one server node,
> no
> client node
> 2) there is no issue for the very first start (i.e. the native storage is
> not created)
> 3) Ignite can be restarted if I delete all data from Native Storage
> folder.
>
> So basically, Ignite server will not able to update/insert data once the
> storage directory exists. Please any help is appreciated.
>
> [16:32:47] Configured failure handler: [hnd=StopNodeOrHaltFailureHandler
> [tryStop=false, timeout=0, super=AbstractFailureHandler
> [ignoredFailureTypes=UnmodifiableSet [SYSTEM_WORKER_BLOCKED,
> SYSTEM_CRITICAL_OPERATION_TIMEOUT]]]]
> [16:32:48] Message queue limit is set to 0 which may lead to potential
> OOMEs
> when running cache operations in FULL_ASYNC or PRIMARY_SYNC modes due to
> message queues growth on sender and receiver sides.
> [16:32:48] Security status [authentication=off, tls/ssl=off]
> [16:32:50] Both Ignite native persistence and CacheStore are configured for
> cache 'FactLine'. This configuration does not guarantee strict consistency
> between CacheStore and Ignite data storage upon restarts. Consult
> documentation for more details.
> [16:32:50] Both Ignite native persistence and CacheStore are configured for
> cache 'InvoiceLine'. This configuration does not guarantee strict
> consistency between CacheStore and Ignite data storage upon restarts.
> Consult documentation for more details.
> [16:32:50] Both Ignite native persistence and CacheStore are configured for
> cache 'DimProduct'. This configuration does not guarantee strict
> consistency
> between CacheStore and Ignite data storage upon restarts. Consult
> documentation for more details.
> [16:32:50] Both Ignite native persistence and CacheStore are configured for
> cache 'Fact'. This configuration does not guarantee strict consistency
> between CacheStore and Ignite data storage upon restarts. Consult
> documentation for more details.
> [16:32:50] Both Ignite native persistence and CacheStore are configured for
> cache 'DimStore'. This configuration does not guarantee strict consistency
> between CacheStore and Ignite data storage upon restarts. Consult
> documentation for more details.
> [16:33:09] Performance suggestions for grid 'MyCluster' (fix if possible)
> [16:33:09] To disable, set -DIGNITE_PERFORMANCE_SUGGESTIONS_DISABLED=true
> [16:33:09] ^-- Enable ATOMIC mode if not using transactions (set
> 'atomicityMode' to ATOMIC)
> [16:33:09] ^-- Enable write-behind to persistent store (set
> 'writeBehindEnabled' to true)
> [16:33:09] ^-- Enable G1 Garbage Collector (add '-XX:+UseG1GC' to JVM
> options)
> [16:33:09] ^-- Specify JVM heap max size (add '-Xmx<size>[g|G|m|M|k|K]'
> to
> JVM options)
> [16:33:09] ^-- Set max direct memory size if getting 'OOME: Direct buffer
> memory' (add '-XX:MaxDirectMemorySize=<size>[g|G|m|M|k|K]' to JVM options)
> [16:33:09] ^-- Disable processing of calls to System.gc() (add
> '-XX:+DisableExplicitGC' to JVM options)
> [16:33:09] Refer to this page for more performance suggestions:
> https://apacheignite.readme.io/docs/jvm-and-system-tuning
> [16:33:09]
> [16:33:09] To start Console Management & Monitoring run
> ignitevisorcmd.{sh|bat}
> [16:33:09] Data Regions Configured:
> [16:33:09] ^-- Default_Region [initSize=10.0 MiB, maxSize=100.0 MiB,
> persistence=true, lazyMemoryAllocation=true]
> [16:33:09]
> [16:33:09] Ignite node started OK (id=53454c70, instance name=MyCluster)
> [16:33:09] Topology snapshot [ver=1, locNode=53454c70, servers=1,
> clients=0,
> state=INACTIVE, CPUs=8, offheap=0.1GB, heap=7.1GB]
> [16:33:09] ^-- Baseline [id=0, size=1, online=1, offline=0]
> [16:33:09] ^-- All baseline nodes are online, will start auto-activation
>
> >>> ******* Start...
>
>
> >>> ******* start populateDimStore...
>
> 16:33:09.755 [main] INFO com.datastax.driver.core.GuavaCompatibility -
> Detected Guava >= 19 in the classpath, using modern compatibility layer
> 16:33:09.757 [main] DEBUG com.datastax.driver.core.SystemProperties -
> com.datastax.driver.NEW_NODE_DELAY_SECONDS is undefined, using default
> value
> 1
> 16:33:09.759 [main] DEBUG com.datastax.driver.core.SystemProperties -
> com.datastax.driver.NOTIF_LOCK_TIMEOUT_SECONDS is undefined, using default
> value 60
> 16:33:09.771 [main] INFO com.datastax.driver.core.SystemProperties -
> com.datastax.driver.USE_NATIVE_CLOCK is defined, using value false
> 16:33:09.771 [main] INFO com.datastax.driver.core.ClockFactory - Using
> java.lang.System clock to generate timestamps.
> 16:33:09.774 [main] DEBUG com.datastax.driver.core.SystemProperties -
> com.datastax.driver.NON_BLOCKING_EXECUTOR_SIZE is undefined, using default
> value 8
> 16:33:09.818 [main] DEBUG com.datastax.driver.core.Cluster - Starting new
> cluster with contact points [127.0.0.1:9042]
> 16:33:09.830 [main] DEBUG
> io.netty.util.internal.logging.InternalLoggerFactory - Using SLF4J as the
> default logging framework
> 16:33:09.840 [main] DEBUG io.netty.util.internal.InternalThreadLocalMap -
> -Dio.netty.threadLocalMap.stringBuilder.initialSize: 1024
> 16:33:09.840 [main] DEBUG io.netty.util.internal.InternalThreadLocalMap -
> -Dio.netty.threadLocalMap.stringBuilder.maxSize: 4096
> 16:33:09.853 [main] DEBUG io.netty.util.internal.PlatformDependent -
> Platform: Windows
> 16:33:09.855 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
> -Dio.netty.noUnsafe: false
> 16:33:09.855 [main] DEBUG io.netty.util.internal.PlatformDependent0 - Java
> version: 8
> 16:33:09.855 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
> sun.misc.Unsafe.theUnsafe: available
> 16:33:09.856 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
> sun.misc.Unsafe.copyMemory: available
> 16:33:09.856 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
> java.nio.Buffer.address: available
> 16:33:09.856 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
> direct
> buffer constructor: available
> 16:33:09.857 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
> java.nio.Bits.unaligned: available, true
> 16:33:09.857 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
> jdk.internal.misc.Unsafe.allocateUninitializedArray(int): unavailable prior
> to Java9
> 16:33:09.857 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
> java.nio.DirectByteBuffer.<init>(long, int): available
> 16:33:09.857 [main] DEBUG io.netty.util.internal.PlatformDependent -
> sun.misc.Unsafe: available
> 16:33:09.857 [main] DEBUG io.netty.util.internal.PlatformDependent -
> -Dio.netty.tmpdir: C:\Users\XINMIN~1\AppData\Local\Temp (java.io.tmpdir)
> 16:33:09.857 [main] DEBUG io.netty.util.internal.PlatformDependent -
> -Dio.netty.bitMode: 64 (sun.arch.data.model)
> 16:33:09.858 [main] DEBUG io.netty.util.internal.PlatformDependent -
> -Dio.netty.maxDirectMemory: 7598505984 bytes
> 16:33:09.858 [main] DEBUG io.netty.util.internal.PlatformDependent -
> -Dio.netty.uninitializedArrayAllocationThreshold: -1
> 16:33:09.859 [main] DEBUG io.netty.util.internal.CleanerJava6 -
> java.nio.ByteBuffer.cleaner(): available
> 16:33:09.859 [main] DEBUG io.netty.util.internal.PlatformDependent -
> -Dio.netty.noPreferDirect: false
> 16:33:09.861 [main] DEBUG com.datastax.driver.core.SystemProperties -
> com.datastax.driver.FORCE_NIO is undefined, using default value false
> 16:33:09.862 [main] INFO com.datastax.driver.core.NettyUtil - Did not find
> Netty's native epoll transport in the classpath, defaulting to NIO.
> 16:33:09.865 [main] DEBUG io.netty.channel.MultithreadEventLoopGroup -
> -Dio.netty.eventLoopThreads: 16
> 16:33:09.872 [main] DEBUG io.netty.channel.nio.NioEventLoop -
> -Dio.netty.noKeySetOptimization: false
> 16:33:09.873 [main] DEBUG io.netty.channel.nio.NioEventLoop -
> -Dio.netty.selectorAutoRebuildThreshold: 512
> 16:33:09.879 [main] DEBUG io.netty.util.internal.PlatformDependent -
> org.jctools-core.MpscChunkedArrayQueue: available
> 16:33:09.895 [main] DEBUG io.netty.util.ResourceLeakDetector -
> -Dio.netty.leakDetection.level: simple
> 16:33:09.895 [main] DEBUG io.netty.util.ResourceLeakDetector -
> -Dio.netty.leakDetection.targetRecords: 4
> 16:33:09.898 [main] DEBUG io.netty.util.ResourceLeakDetectorFactory -
> Loaded
> default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@95eb320
> 16:33:09.902 [main] DEBUG com.datastax.driver.core.SystemProperties -
> com.datastax.driver.EXTENDED_PEER_CHECK is undefined, using default value
> true
> 16:33:09.955 [main] DEBUG com.datastax.driver.core.Host.STATES -
> [127.0.0.1:9042] preparing to open 1 new connections, total = 1
> 16:33:09.958 [main] DEBUG com.datastax.driver.core.SystemProperties -
> com.datastax.driver.DISABLE_COALESCING is undefined, using default value
> false
> 16:33:09.982 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
> -Dio.netty.allocator.numHeapArenas: 16
> 16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
> -Dio.netty.allocator.numDirectArenas: 16
> 16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
> -Dio.netty.allocator.pageSize: 8192
> 16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
> -Dio.netty.allocator.maxOrder: 11
> 16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
> -Dio.netty.allocator.chunkSize: 16777216
> 16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
> -Dio.netty.allocator.smallCacheSize: 256
> 16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
> -Dio.netty.allocator.normalCacheSize: 64
> 16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
> -Dio.netty.allocator.maxCachedBufferCapacity: 32768
> 16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
> -Dio.netty.allocator.cacheTrimInterval: 8192
> 16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
> -Dio.netty.allocator.cacheTrimIntervalMillis: 0
> 16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
> -Dio.netty.allocator.useCacheForAllThreads: true
> 16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
> -Dio.netty.allocator.maxCachedByteBuffersPerChunk: 1023
> 16:33:10.000 [main] DEBUG io.netty.channel.DefaultChannelId -
> -Dio.netty.processId: 16172 (auto-detected)
> 16:33:10.002 [main] DEBUG io.netty.util.NetUtil -
> -Djava.net.preferIPv4Stack: false
> 16:33:10.002 [main] DEBUG io.netty.util.NetUtil -
> -Djava.net.preferIPv6Addresses: false
> 16:33:10.225 [main] DEBUG io.netty.util.NetUtil - Loopback interface: lo
> (Software Loopback Interface 1, 127.0.0.1)
> 16:33:10.225 [main] DEBUG io.netty.util.NetUtil - Failed to get SOMAXCONN
> from sysctl and file \proc\sys\net\core\somaxconn. Default: 200
> 16:33:10.457 [main] DEBUG io.netty.channel.DefaultChannelId -
> -Dio.netty.machineId: 00:ff:1f:ff:fe:aa:da:94 (auto-detected)
> 16:33:10.473 [main] DEBUG io.netty.buffer.ByteBufUtil -
> -Dio.netty.allocator.type: pooled
> 16:33:10.473 [main] DEBUG io.netty.buffer.ByteBufUtil -
> -Dio.netty.threadLocalDirectBufferSize: 0
> 16:33:10.473 [main] DEBUG io.netty.buffer.ByteBufUtil -
> -Dio.netty.maxThreadLocalCharBufferSize: 16384
> 16:33:10.497 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
> inFlight=0, closed=false] Connection established, initializing transport
> 16:33:10.521 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler -
> -Dio.netty.recycler.maxCapacityPerThread: 4096
> 16:33:10.521 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler -
> -Dio.netty.recycler.maxSharedCapacityFactor: 2
> 16:33:10.521 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler -
> -Dio.netty.recycler.linkCapacity: 16
> 16:33:10.521 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler -
> -Dio.netty.recycler.ratio: 8
> 16:33:10.521 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler -
> -Dio.netty.recycler.delayedQueue.ratio: 8
> 16:33:10.527 [cluster1-nio-worker-0] DEBUG io.netty.buffer.AbstractByteBuf
> -
> -Dio.netty.buffer.checkAccessible: true
> 16:33:10.527 [cluster1-nio-worker-0] DEBUG io.netty.buffer.AbstractByteBuf
> -
> -Dio.netty.buffer.checkBounds: true
> 16:33:10.527 [cluster1-nio-worker-0] DEBUG
> io.netty.util.ResourceLeakDetectorFactory - Loaded default
> ResourceLeakDetector: io.netty.util.ResourceLeakDetector@847df0e
> 16:33:10.542 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.SystemProperties -
> com.datastax.driver.NATIVE_TRANSPORT_MAX_FRAME_SIZE_IN_MB is undefined,
> using default value 256
> 16:33:10.543 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Host.STATES - [127.0.0.1:9042]
> Connection[127.0.0.1:9042-1, inFlight=0, closed=false] Transport
> initialized, connection ready
> 16:33:10.544 [main] DEBUG com.datastax.driver.core.ControlConnection -
> [Control connection] Refreshing node list and token map
> 16:33:10.597 [main] DEBUG com.datastax.driver.core.ControlConnection -
> [Control connection] Refreshing schema
> 16:33:10.806 [main] DEBUG com.datastax.driver.core.Host.STATES - [Control
> connection] established to 127.0.0.1:9042
> 16:33:10.807 [main] INFO
> com.datastax.driver.core.policies.DCAwareRoundRobinPolicy - Using
> data-center name 'datacenter1' for DCAwareRoundRobinPolicy (if this is
> incorrect, please provide the correct datacenter name with
> DCAwareRoundRobinPolicy constructor)
> 16:33:10.808 [main] INFO com.datastax.driver.core.Cluster - New Cassandra
> host 127.0.0.1:9042 added
> 16:33:10.811 [main] DEBUG com.datastax.driver.core.SystemProperties -
> com.datastax.driver.CHECK_IO_DEADLOCKS is undefined, using default value
> true
> 16:33:10.814 [main] DEBUG com.datastax.driver.core.Host.STATES -
> [127.0.0.1:9042] preparing to open 1 new connections, total = 2
> 16:33:10.820 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
> inFlight=0, closed=false] Connection established, initializing transport
> 16:33:10.831 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Host.STATES - [127.0.0.1:9042]
> Connection[127.0.0.1:9042-2, inFlight=0, closed=false] Transport
> initialized, connection ready
> 16:33:10.833 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.HostConnectionPool - Created connection pool to
> host 127.0.0.1:9042 (1 connections needed, 1 successfully opened)
> 16:33:10.833 [cluster1-nio-worker-1] DEBUG com.datastax.driver.core.Session
> - Added connection pool for 127.0.0.1:9042
> [16:33:10,855][SEVERE][main][CassandraCacheStore] Failed to apply 1
> mutations performed withing Ignite transaction into Cassandra
> class org.apache.ignite.IgniteException: Failed to apply 1 mutations
> performed withing Ignite transaction into Cassandra
> at
>
> org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:516)
> at
>
> org.apache.ignite.cache.store.cassandra.CassandraCacheStore.sessionEnd(CassandraCacheStore.java:172)
> at
>
> org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.sessionEnd(GridCacheStoreManagerAdapter.java:800)
> at
>
> org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter.sessionEnd(IgniteTxAdapter.java:1410)
> at
>
> org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter.batchStoreCommit(IgniteTxAdapter.java:1591)
> at
>
> org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter.userCommit(IgniteTxLocalAdapter.java:592)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.localFinish(GridNearTxLocal.java:3850)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture.doFinish(GridNearTxFinishFuture.java:440)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture.finish(GridNearTxFinishFuture.java:390)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$25.apply(GridNearTxLocal.java:4129)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$25.apply(GridNearTxLocal.java:4118)
> at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:399)
> at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.listen(GridFutureAdapter.java:354)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.commitNearTxLocalAsync(GridNearTxLocal.java:4118)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.optimisticPutFuture(GridNearTxLocal.java:3012)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.putAsync0(GridNearTxLocal.java:738)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.putAsync(GridNearTxLocal.java:493)
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheAdapter$22.op(GridCacheAdapter.java:2596)
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheAdapter$22.op(GridCacheAdapter.java:2594)
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheAdapter.syncOp(GridCacheAdapter.java:4332)
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheAdapter.put0(GridCacheAdapter.java:2594)
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2575)
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2552)
> at
>
> org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.put(IgniteCacheProxyImpl.java:1302)
> at
>
> org.apache.ignite.internal.processors.cache.GatewayProtectedCacheProxy.put(GatewayProtectedCacheProxy.java:856)
> at
>
> com.procurant.test.partition.FactPartitionNativePersistenceCassandraToCacheTester.populateStore(FactPartitionNativePersistenceCassandraToCacheTester.java:120)
> at
>
> com.procurant.test.partition.FactPartitionNativePersistenceCassandraToCacheTester.main(FactPartitionNativePersistenceCassandraToCacheTester.java:91)
> Caused by: java.lang.NullPointerException
> at
>
> org.apache.ignite.cache.store.cassandra.persistence.PojoField.getValueFromObject(PojoField.java:167)
> at
>
> org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.bindValues(PersistenceController.java:448)
> at
>
> org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.bindKeyValue(PersistenceController.java:203)
> at
>
> org.apache.ignite.cache.store.cassandra.session.transaction.WriteMutation.bindStatement(WriteMutation.java:58)
> at
>
> org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:479)
> ... 26 more
> Exception in thread "main" javax.cache.CacheException: class
> org.apache.ignite.transactions.TransactionRollbackException: Transaction
> has
> been rolled back: 4771d149471-00000000-0c9e-2cf6-0000-000000000001
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheUtils.convertToCacheException(GridCacheUtils.java:1317)
> at
>
> org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.cacheException(IgniteCacheProxyImpl.java:2069)
> at
>
> org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.put(IgniteCacheProxyImpl.java:1305)
> at
>
> org.apache.ignite.internal.processors.cache.GatewayProtectedCacheProxy.put(GatewayProtectedCacheProxy.java:856)
> at
>
> com.procurant.test.partition.FactPartitionNativePersistenceCassandraToCacheTester.populateStore(FactPartitionNativePersistenceCassandraToCacheTester.java:120)
> at
>
> com.procurant.test.partition.FactPartitionNativePersistenceCassandraToCacheTester.main(FactPartitionNativePersistenceCassandraToCacheTester.java:91)
> Caused by: class
> org.apache.ignite.transactions.TransactionRollbackException: Transaction
> has
> been rolled back: 4771d149471-00000000-0c9e-2cf6-0000-000000000001
> at
> org.apache.ignite.internal.util.IgniteUtils$11.apply(IgniteUtils.java:943)
> at
> org.apache.ignite.internal.util.IgniteUtils$11.apply(IgniteUtils.java:941)
> ... 6 more
> Caused by: class
> org.apache.ignite.internal.transactions.IgniteTxRollbackCheckedException:
> Transaction has been rolled back:
> 4771d149471-00000000-0c9e-2cf6-0000-000000000001
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheAdapter.syncOp(GridCacheAdapter.java:4351)
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheAdapter.put0(GridCacheAdapter.java:2594)
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2575)
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2552)
> at
>
> org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.put(IgniteCacheProxyImpl.java:1302)
> ... 3 more
> Caused by: class org.apache.ignite.IgniteCheckedException: Failed to apply
> 1
> mutations performed withing Ignite transaction into Cassandra
> at
> org.apache.ignite.internal.util.IgniteUtils.cast(IgniteUtils.java:7507)
> at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.resolve(GridFutureAdapter.java:260)
> at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.get0(GridFutureAdapter.java:172)
> at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:141)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$18.applyx(GridNearTxLocal.java:3017)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$18.applyx(GridNearTxLocal.java:3013)
> at
>
> org.apache.ignite.internal.util.lang.IgniteClosureX.apply(IgniteClosureX.java:38)
> at
>
> org.apache.ignite.internal.util.future.GridFutureChainListener.applyCallback(GridFutureChainListener.java:78)
> at
>
> org.apache.ignite.internal.util.future.GridFutureChainListener.apply(GridFutureChainListener.java:70)
> at
>
> org.apache.ignite.internal.util.future.GridFutureChainListener.apply(GridFutureChainListener.java:30)
> at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:399)
> at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.listen(GridFutureAdapter.java:354)
> at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter$ChainFuture.<init>(GridFutureAdapter.java:588)
> at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.chain(GridFutureAdapter.java:361)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.optimisticPutFuture(GridNearTxLocal.java:3012)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.putAsync0(GridNearTxLocal.java:738)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.putAsync(GridNearTxLocal.java:493)
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheAdapter$22.op(GridCacheAdapter.java:2596)
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheAdapter$22.op(GridCacheAdapter.java:2594)
> at
>
> org.apache.ignite.internal.processors.cache.GridCacheAdapter.syncOp(GridCacheAdapter.java:4332)
> ... 7 more
> Caused by: class org.apache.ignite.IgniteException: Failed to apply 1
> mutations performed withing Ignite transaction into Cassandra
> at
>
> org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:532)
> at
>
> org.apache.ignite.cache.store.cassandra.CassandraCacheStore.sessionEnd(CassandraCacheStore.java:172)
> at
>
> org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.sessionEnd(GridCacheStoreManagerAdapter.java:800)
> at
>
> org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter.sessionEnd(IgniteTxAdapter.java:1410)
> at
>
> org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter.batchStoreCommit(IgniteTxAdapter.java:1591)
> at
>
> org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter.userCommit(IgniteTxLocalAdapter.java:592)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.localFinish(GridNearTxLocal.java:3850)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture.doFinish(GridNearTxFinishFuture.java:440)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture.finish(GridNearTxFinishFuture.java:390)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$25.apply(GridNearTxLocal.java:4129)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$25.apply(GridNearTxLocal.java:4118)
> at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:399)
> at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.listen(GridFutureAdapter.java:354)
> at
>
> org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.commitNearTxLocalAsync(GridNearTxLocal.java:4118)
> ... 13 more
> Caused by: class org.apache.ignite.IgniteException: Failed to apply 1
> mutations performed withing Ignite transaction into Cassandra
> at
>
> org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:516)
> ... 26 more
> Caused by: java.lang.NullPointerException
> at
>
> org.apache.ignite.cache.store.cassandra.persistence.PojoField.getValueFromObject(PojoField.java:167)
> at
>
> org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.bindValues(PersistenceController.java:448)
> at
>
> org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.bindKeyValue(PersistenceController.java:203)
> at
>
> org.apache.ignite.cache.store.cassandra.session.transaction.WriteMutation.bindStatement(WriteMutation.java:58)
> at
>
> org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:479)
> ... 26 more
> 16:33:40.658 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
> inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
> 16:33:40.660 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
> inFlight=0, closed=false] heartbeat query succeeded
> 16:33:40.860 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
> inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
> 16:33:40.861 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
> inFlight=0, closed=false] heartbeat query succeeded
> 16:34:10.677 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
> inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
> 16:34:10.678 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
> inFlight=0, closed=false] heartbeat query succeeded
> 16:34:10.864 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
> inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
> 16:34:10.865 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
> inFlight=0, closed=false] heartbeat query succeeded
> 16:34:40.679 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
> inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
> 16:34:40.680 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
> inFlight=0, closed=false] heartbeat query succeeded
> 16:34:40.881 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
> inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
> 16:34:40.882 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
> inFlight=0, closed=false] heartbeat query succeeded
> 16:35:10.697 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
> inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
> 16:35:10.699 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
> inFlight=0, closed=false] heartbeat query succeeded
> 16:35:10.883 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
> inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
> 16:35:10.884 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
> inFlight=0, closed=false] heartbeat query succeeded
> 16:35:40.713 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
> inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
> 16:35:40.714 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
> inFlight=0, closed=false] heartbeat query succeeded
> 16:35:40.885 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
> inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
> 16:35:40.886 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
> inFlight=0, closed=false] heartbeat query succeeded
> 16:36:10.727 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
> inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
> 16:36:10.729 [cluster1-nio-worker-0] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
> inFlight=0, closed=false] heartbeat query succeeded
> 16:36:10.899 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
> inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
> 16:36:10.900 [cluster1-nio-worker-1] DEBUG
> com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
> inFlight=0, closed=false] heartbeat query succeeded
>
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>
Re: Getting NullPointerException during commit into cassandra,
after reconnecting to ignite server
Posted by xmw45688 <xw...@procurant.com>.
I got this exception for ignite 2.8.0. When the note restarted and the data
is inserted into the cache and Cassandra store. Please note
1) my setup is that Native Persistence is enabled. just one server node, no
client node
2) there is no issue for the very first start (i.e. the native storage is
not created)
3) Ignite can be restarted if I delete all data from Native Storage folder.
So basically, Ignite server will not able to update/insert data once the
storage directory exists. Please any help is appreciated.
[16:32:47] Configured failure handler: [hnd=StopNodeOrHaltFailureHandler
[tryStop=false, timeout=0, super=AbstractFailureHandler
[ignoredFailureTypes=UnmodifiableSet [SYSTEM_WORKER_BLOCKED,
SYSTEM_CRITICAL_OPERATION_TIMEOUT]]]]
[16:32:48] Message queue limit is set to 0 which may lead to potential OOMEs
when running cache operations in FULL_ASYNC or PRIMARY_SYNC modes due to
message queues growth on sender and receiver sides.
[16:32:48] Security status [authentication=off, tls/ssl=off]
[16:32:50] Both Ignite native persistence and CacheStore are configured for
cache 'FactLine'. This configuration does not guarantee strict consistency
between CacheStore and Ignite data storage upon restarts. Consult
documentation for more details.
[16:32:50] Both Ignite native persistence and CacheStore are configured for
cache 'InvoiceLine'. This configuration does not guarantee strict
consistency between CacheStore and Ignite data storage upon restarts.
Consult documentation for more details.
[16:32:50] Both Ignite native persistence and CacheStore are configured for
cache 'DimProduct'. This configuration does not guarantee strict consistency
between CacheStore and Ignite data storage upon restarts. Consult
documentation for more details.
[16:32:50] Both Ignite native persistence and CacheStore are configured for
cache 'Fact'. This configuration does not guarantee strict consistency
between CacheStore and Ignite data storage upon restarts. Consult
documentation for more details.
[16:32:50] Both Ignite native persistence and CacheStore are configured for
cache 'DimStore'. This configuration does not guarantee strict consistency
between CacheStore and Ignite data storage upon restarts. Consult
documentation for more details.
[16:33:09] Performance suggestions for grid 'MyCluster' (fix if possible)
[16:33:09] To disable, set -DIGNITE_PERFORMANCE_SUGGESTIONS_DISABLED=true
[16:33:09] ^-- Enable ATOMIC mode if not using transactions (set
'atomicityMode' to ATOMIC)
[16:33:09] ^-- Enable write-behind to persistent store (set
'writeBehindEnabled' to true)
[16:33:09] ^-- Enable G1 Garbage Collector (add '-XX:+UseG1GC' to JVM
options)
[16:33:09] ^-- Specify JVM heap max size (add '-Xmx<size>[g|G|m|M|k|K]' to
JVM options)
[16:33:09] ^-- Set max direct memory size if getting 'OOME: Direct buffer
memory' (add '-XX:MaxDirectMemorySize=<size>[g|G|m|M|k|K]' to JVM options)
[16:33:09] ^-- Disable processing of calls to System.gc() (add
'-XX:+DisableExplicitGC' to JVM options)
[16:33:09] Refer to this page for more performance suggestions:
https://apacheignite.readme.io/docs/jvm-and-system-tuning
[16:33:09]
[16:33:09] To start Console Management & Monitoring run
ignitevisorcmd.{sh|bat}
[16:33:09] Data Regions Configured:
[16:33:09] ^-- Default_Region [initSize=10.0 MiB, maxSize=100.0 MiB,
persistence=true, lazyMemoryAllocation=true]
[16:33:09]
[16:33:09] Ignite node started OK (id=53454c70, instance name=MyCluster)
[16:33:09] Topology snapshot [ver=1, locNode=53454c70, servers=1, clients=0,
state=INACTIVE, CPUs=8, offheap=0.1GB, heap=7.1GB]
[16:33:09] ^-- Baseline [id=0, size=1, online=1, offline=0]
[16:33:09] ^-- All baseline nodes are online, will start auto-activation
>>> ******* Start...
>>> ******* start populateDimStore...
16:33:09.755 [main] INFO com.datastax.driver.core.GuavaCompatibility -
Detected Guava >= 19 in the classpath, using modern compatibility layer
16:33:09.757 [main] DEBUG com.datastax.driver.core.SystemProperties -
com.datastax.driver.NEW_NODE_DELAY_SECONDS is undefined, using default value
1
16:33:09.759 [main] DEBUG com.datastax.driver.core.SystemProperties -
com.datastax.driver.NOTIF_LOCK_TIMEOUT_SECONDS is undefined, using default
value 60
16:33:09.771 [main] INFO com.datastax.driver.core.SystemProperties -
com.datastax.driver.USE_NATIVE_CLOCK is defined, using value false
16:33:09.771 [main] INFO com.datastax.driver.core.ClockFactory - Using
java.lang.System clock to generate timestamps.
16:33:09.774 [main] DEBUG com.datastax.driver.core.SystemProperties -
com.datastax.driver.NON_BLOCKING_EXECUTOR_SIZE is undefined, using default
value 8
16:33:09.818 [main] DEBUG com.datastax.driver.core.Cluster - Starting new
cluster with contact points [127.0.0.1:9042]
16:33:09.830 [main] DEBUG
io.netty.util.internal.logging.InternalLoggerFactory - Using SLF4J as the
default logging framework
16:33:09.840 [main] DEBUG io.netty.util.internal.InternalThreadLocalMap -
-Dio.netty.threadLocalMap.stringBuilder.initialSize: 1024
16:33:09.840 [main] DEBUG io.netty.util.internal.InternalThreadLocalMap -
-Dio.netty.threadLocalMap.stringBuilder.maxSize: 4096
16:33:09.853 [main] DEBUG io.netty.util.internal.PlatformDependent -
Platform: Windows
16:33:09.855 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
-Dio.netty.noUnsafe: false
16:33:09.855 [main] DEBUG io.netty.util.internal.PlatformDependent0 - Java
version: 8
16:33:09.855 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
sun.misc.Unsafe.theUnsafe: available
16:33:09.856 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
sun.misc.Unsafe.copyMemory: available
16:33:09.856 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
java.nio.Buffer.address: available
16:33:09.856 [main] DEBUG io.netty.util.internal.PlatformDependent0 - direct
buffer constructor: available
16:33:09.857 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
java.nio.Bits.unaligned: available, true
16:33:09.857 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
jdk.internal.misc.Unsafe.allocateUninitializedArray(int): unavailable prior
to Java9
16:33:09.857 [main] DEBUG io.netty.util.internal.PlatformDependent0 -
java.nio.DirectByteBuffer.<init>(long, int): available
16:33:09.857 [main] DEBUG io.netty.util.internal.PlatformDependent -
sun.misc.Unsafe: available
16:33:09.857 [main] DEBUG io.netty.util.internal.PlatformDependent -
-Dio.netty.tmpdir: C:\Users\XINMIN~1\AppData\Local\Temp (java.io.tmpdir)
16:33:09.857 [main] DEBUG io.netty.util.internal.PlatformDependent -
-Dio.netty.bitMode: 64 (sun.arch.data.model)
16:33:09.858 [main] DEBUG io.netty.util.internal.PlatformDependent -
-Dio.netty.maxDirectMemory: 7598505984 bytes
16:33:09.858 [main] DEBUG io.netty.util.internal.PlatformDependent -
-Dio.netty.uninitializedArrayAllocationThreshold: -1
16:33:09.859 [main] DEBUG io.netty.util.internal.CleanerJava6 -
java.nio.ByteBuffer.cleaner(): available
16:33:09.859 [main] DEBUG io.netty.util.internal.PlatformDependent -
-Dio.netty.noPreferDirect: false
16:33:09.861 [main] DEBUG com.datastax.driver.core.SystemProperties -
com.datastax.driver.FORCE_NIO is undefined, using default value false
16:33:09.862 [main] INFO com.datastax.driver.core.NettyUtil - Did not find
Netty's native epoll transport in the classpath, defaulting to NIO.
16:33:09.865 [main] DEBUG io.netty.channel.MultithreadEventLoopGroup -
-Dio.netty.eventLoopThreads: 16
16:33:09.872 [main] DEBUG io.netty.channel.nio.NioEventLoop -
-Dio.netty.noKeySetOptimization: false
16:33:09.873 [main] DEBUG io.netty.channel.nio.NioEventLoop -
-Dio.netty.selectorAutoRebuildThreshold: 512
16:33:09.879 [main] DEBUG io.netty.util.internal.PlatformDependent -
org.jctools-core.MpscChunkedArrayQueue: available
16:33:09.895 [main] DEBUG io.netty.util.ResourceLeakDetector -
-Dio.netty.leakDetection.level: simple
16:33:09.895 [main] DEBUG io.netty.util.ResourceLeakDetector -
-Dio.netty.leakDetection.targetRecords: 4
16:33:09.898 [main] DEBUG io.netty.util.ResourceLeakDetectorFactory - Loaded
default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@95eb320
16:33:09.902 [main] DEBUG com.datastax.driver.core.SystemProperties -
com.datastax.driver.EXTENDED_PEER_CHECK is undefined, using default value
true
16:33:09.955 [main] DEBUG com.datastax.driver.core.Host.STATES -
[127.0.0.1:9042] preparing to open 1 new connections, total = 1
16:33:09.958 [main] DEBUG com.datastax.driver.core.SystemProperties -
com.datastax.driver.DISABLE_COALESCING is undefined, using default value
false
16:33:09.982 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.numHeapArenas: 16
16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.numDirectArenas: 16
16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.pageSize: 8192
16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.maxOrder: 11
16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.chunkSize: 16777216
16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.smallCacheSize: 256
16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.normalCacheSize: 64
16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.maxCachedBufferCapacity: 32768
16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.cacheTrimInterval: 8192
16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.cacheTrimIntervalMillis: 0
16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.useCacheForAllThreads: true
16:33:09.983 [main] DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.maxCachedByteBuffersPerChunk: 1023
16:33:10.000 [main] DEBUG io.netty.channel.DefaultChannelId -
-Dio.netty.processId: 16172 (auto-detected)
16:33:10.002 [main] DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv4Stack: false
16:33:10.002 [main] DEBUG io.netty.util.NetUtil -
-Djava.net.preferIPv6Addresses: false
16:33:10.225 [main] DEBUG io.netty.util.NetUtil - Loopback interface: lo
(Software Loopback Interface 1, 127.0.0.1)
16:33:10.225 [main] DEBUG io.netty.util.NetUtil - Failed to get SOMAXCONN
from sysctl and file \proc\sys\net\core\somaxconn. Default: 200
16:33:10.457 [main] DEBUG io.netty.channel.DefaultChannelId -
-Dio.netty.machineId: 00:ff:1f:ff:fe:aa:da:94 (auto-detected)
16:33:10.473 [main] DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.allocator.type: pooled
16:33:10.473 [main] DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.threadLocalDirectBufferSize: 0
16:33:10.473 [main] DEBUG io.netty.buffer.ByteBufUtil -
-Dio.netty.maxThreadLocalCharBufferSize: 16384
16:33:10.497 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
inFlight=0, closed=false] Connection established, initializing transport
16:33:10.521 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler -
-Dio.netty.recycler.maxCapacityPerThread: 4096
16:33:10.521 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler -
-Dio.netty.recycler.maxSharedCapacityFactor: 2
16:33:10.521 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler -
-Dio.netty.recycler.linkCapacity: 16
16:33:10.521 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler -
-Dio.netty.recycler.ratio: 8
16:33:10.521 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler -
-Dio.netty.recycler.delayedQueue.ratio: 8
16:33:10.527 [cluster1-nio-worker-0] DEBUG io.netty.buffer.AbstractByteBuf -
-Dio.netty.buffer.checkAccessible: true
16:33:10.527 [cluster1-nio-worker-0] DEBUG io.netty.buffer.AbstractByteBuf -
-Dio.netty.buffer.checkBounds: true
16:33:10.527 [cluster1-nio-worker-0] DEBUG
io.netty.util.ResourceLeakDetectorFactory - Loaded default
ResourceLeakDetector: io.netty.util.ResourceLeakDetector@847df0e
16:33:10.542 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.SystemProperties -
com.datastax.driver.NATIVE_TRANSPORT_MAX_FRAME_SIZE_IN_MB is undefined,
using default value 256
16:33:10.543 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Host.STATES - [127.0.0.1:9042]
Connection[127.0.0.1:9042-1, inFlight=0, closed=false] Transport
initialized, connection ready
16:33:10.544 [main] DEBUG com.datastax.driver.core.ControlConnection -
[Control connection] Refreshing node list and token map
16:33:10.597 [main] DEBUG com.datastax.driver.core.ControlConnection -
[Control connection] Refreshing schema
16:33:10.806 [main] DEBUG com.datastax.driver.core.Host.STATES - [Control
connection] established to 127.0.0.1:9042
16:33:10.807 [main] INFO
com.datastax.driver.core.policies.DCAwareRoundRobinPolicy - Using
data-center name 'datacenter1' for DCAwareRoundRobinPolicy (if this is
incorrect, please provide the correct datacenter name with
DCAwareRoundRobinPolicy constructor)
16:33:10.808 [main] INFO com.datastax.driver.core.Cluster - New Cassandra
host 127.0.0.1:9042 added
16:33:10.811 [main] DEBUG com.datastax.driver.core.SystemProperties -
com.datastax.driver.CHECK_IO_DEADLOCKS is undefined, using default value
true
16:33:10.814 [main] DEBUG com.datastax.driver.core.Host.STATES -
[127.0.0.1:9042] preparing to open 1 new connections, total = 2
16:33:10.820 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
inFlight=0, closed=false] Connection established, initializing transport
16:33:10.831 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Host.STATES - [127.0.0.1:9042]
Connection[127.0.0.1:9042-2, inFlight=0, closed=false] Transport
initialized, connection ready
16:33:10.833 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.HostConnectionPool - Created connection pool to
host 127.0.0.1:9042 (1 connections needed, 1 successfully opened)
16:33:10.833 [cluster1-nio-worker-1] DEBUG com.datastax.driver.core.Session
- Added connection pool for 127.0.0.1:9042
[16:33:10,855][SEVERE][main][CassandraCacheStore] Failed to apply 1
mutations performed withing Ignite transaction into Cassandra
class org.apache.ignite.IgniteException: Failed to apply 1 mutations
performed withing Ignite transaction into Cassandra
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:516)
at
org.apache.ignite.cache.store.cassandra.CassandraCacheStore.sessionEnd(CassandraCacheStore.java:172)
at
org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.sessionEnd(GridCacheStoreManagerAdapter.java:800)
at
org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter.sessionEnd(IgniteTxAdapter.java:1410)
at
org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter.batchStoreCommit(IgniteTxAdapter.java:1591)
at
org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter.userCommit(IgniteTxLocalAdapter.java:592)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.localFinish(GridNearTxLocal.java:3850)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture.doFinish(GridNearTxFinishFuture.java:440)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture.finish(GridNearTxFinishFuture.java:390)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$25.apply(GridNearTxLocal.java:4129)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$25.apply(GridNearTxLocal.java:4118)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:399)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.listen(GridFutureAdapter.java:354)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.commitNearTxLocalAsync(GridNearTxLocal.java:4118)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.optimisticPutFuture(GridNearTxLocal.java:3012)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.putAsync0(GridNearTxLocal.java:738)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.putAsync(GridNearTxLocal.java:493)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter$22.op(GridCacheAdapter.java:2596)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter$22.op(GridCacheAdapter.java:2594)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.syncOp(GridCacheAdapter.java:4332)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.put0(GridCacheAdapter.java:2594)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2575)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2552)
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.put(IgniteCacheProxyImpl.java:1302)
at
org.apache.ignite.internal.processors.cache.GatewayProtectedCacheProxy.put(GatewayProtectedCacheProxy.java:856)
at
com.procurant.test.partition.FactPartitionNativePersistenceCassandraToCacheTester.populateStore(FactPartitionNativePersistenceCassandraToCacheTester.java:120)
at
com.procurant.test.partition.FactPartitionNativePersistenceCassandraToCacheTester.main(FactPartitionNativePersistenceCassandraToCacheTester.java:91)
Caused by: java.lang.NullPointerException
at
org.apache.ignite.cache.store.cassandra.persistence.PojoField.getValueFromObject(PojoField.java:167)
at
org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.bindValues(PersistenceController.java:448)
at
org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.bindKeyValue(PersistenceController.java:203)
at
org.apache.ignite.cache.store.cassandra.session.transaction.WriteMutation.bindStatement(WriteMutation.java:58)
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:479)
... 26 more
Exception in thread "main" javax.cache.CacheException: class
org.apache.ignite.transactions.TransactionRollbackException: Transaction has
been rolled back: 4771d149471-00000000-0c9e-2cf6-0000-000000000001
at
org.apache.ignite.internal.processors.cache.GridCacheUtils.convertToCacheException(GridCacheUtils.java:1317)
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.cacheException(IgniteCacheProxyImpl.java:2069)
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.put(IgniteCacheProxyImpl.java:1305)
at
org.apache.ignite.internal.processors.cache.GatewayProtectedCacheProxy.put(GatewayProtectedCacheProxy.java:856)
at
com.procurant.test.partition.FactPartitionNativePersistenceCassandraToCacheTester.populateStore(FactPartitionNativePersistenceCassandraToCacheTester.java:120)
at
com.procurant.test.partition.FactPartitionNativePersistenceCassandraToCacheTester.main(FactPartitionNativePersistenceCassandraToCacheTester.java:91)
Caused by: class
org.apache.ignite.transactions.TransactionRollbackException: Transaction has
been rolled back: 4771d149471-00000000-0c9e-2cf6-0000-000000000001
at
org.apache.ignite.internal.util.IgniteUtils$11.apply(IgniteUtils.java:943)
at
org.apache.ignite.internal.util.IgniteUtils$11.apply(IgniteUtils.java:941)
... 6 more
Caused by: class
org.apache.ignite.internal.transactions.IgniteTxRollbackCheckedException:
Transaction has been rolled back:
4771d149471-00000000-0c9e-2cf6-0000-000000000001
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.syncOp(GridCacheAdapter.java:4351)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.put0(GridCacheAdapter.java:2594)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2575)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.put(GridCacheAdapter.java:2552)
at
org.apache.ignite.internal.processors.cache.IgniteCacheProxyImpl.put(IgniteCacheProxyImpl.java:1302)
... 3 more
Caused by: class org.apache.ignite.IgniteCheckedException: Failed to apply 1
mutations performed withing Ignite transaction into Cassandra
at org.apache.ignite.internal.util.IgniteUtils.cast(IgniteUtils.java:7507)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.resolve(GridFutureAdapter.java:260)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.get0(GridFutureAdapter.java:172)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:141)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$18.applyx(GridNearTxLocal.java:3017)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$18.applyx(GridNearTxLocal.java:3013)
at
org.apache.ignite.internal.util.lang.IgniteClosureX.apply(IgniteClosureX.java:38)
at
org.apache.ignite.internal.util.future.GridFutureChainListener.applyCallback(GridFutureChainListener.java:78)
at
org.apache.ignite.internal.util.future.GridFutureChainListener.apply(GridFutureChainListener.java:70)
at
org.apache.ignite.internal.util.future.GridFutureChainListener.apply(GridFutureChainListener.java:30)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:399)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.listen(GridFutureAdapter.java:354)
at
org.apache.ignite.internal.util.future.GridFutureAdapter$ChainFuture.<init>(GridFutureAdapter.java:588)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.chain(GridFutureAdapter.java:361)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.optimisticPutFuture(GridNearTxLocal.java:3012)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.putAsync0(GridNearTxLocal.java:738)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.putAsync(GridNearTxLocal.java:493)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter$22.op(GridCacheAdapter.java:2596)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter$22.op(GridCacheAdapter.java:2594)
at
org.apache.ignite.internal.processors.cache.GridCacheAdapter.syncOp(GridCacheAdapter.java:4332)
... 7 more
Caused by: class org.apache.ignite.IgniteException: Failed to apply 1
mutations performed withing Ignite transaction into Cassandra
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:532)
at
org.apache.ignite.cache.store.cassandra.CassandraCacheStore.sessionEnd(CassandraCacheStore.java:172)
at
org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.sessionEnd(GridCacheStoreManagerAdapter.java:800)
at
org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter.sessionEnd(IgniteTxAdapter.java:1410)
at
org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter.batchStoreCommit(IgniteTxAdapter.java:1591)
at
org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter.userCommit(IgniteTxLocalAdapter.java:592)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.localFinish(GridNearTxLocal.java:3850)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture.doFinish(GridNearTxFinishFuture.java:440)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxFinishFuture.finish(GridNearTxFinishFuture.java:390)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$25.apply(GridNearTxLocal.java:4129)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal$25.apply(GridNearTxLocal.java:4118)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:399)
at
org.apache.ignite.internal.util.future.GridFutureAdapter.listen(GridFutureAdapter.java:354)
at
org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal.commitNearTxLocalAsync(GridNearTxLocal.java:4118)
... 13 more
Caused by: class org.apache.ignite.IgniteException: Failed to apply 1
mutations performed withing Ignite transaction into Cassandra
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:516)
... 26 more
Caused by: java.lang.NullPointerException
at
org.apache.ignite.cache.store.cassandra.persistence.PojoField.getValueFromObject(PojoField.java:167)
at
org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.bindValues(PersistenceController.java:448)
at
org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.bindKeyValue(PersistenceController.java:203)
at
org.apache.ignite.cache.store.cassandra.session.transaction.WriteMutation.bindStatement(WriteMutation.java:58)
at
org.apache.ignite.cache.store.cassandra.session.CassandraSessionImpl.execute(CassandraSessionImpl.java:479)
... 26 more
16:33:40.658 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
16:33:40.660 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
inFlight=0, closed=false] heartbeat query succeeded
16:33:40.860 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
16:33:40.861 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
inFlight=0, closed=false] heartbeat query succeeded
16:34:10.677 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
16:34:10.678 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
inFlight=0, closed=false] heartbeat query succeeded
16:34:10.864 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
16:34:10.865 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
inFlight=0, closed=false] heartbeat query succeeded
16:34:40.679 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
16:34:40.680 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
inFlight=0, closed=false] heartbeat query succeeded
16:34:40.881 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
16:34:40.882 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
inFlight=0, closed=false] heartbeat query succeeded
16:35:10.697 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
16:35:10.699 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
inFlight=0, closed=false] heartbeat query succeeded
16:35:10.883 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
16:35:10.884 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
inFlight=0, closed=false] heartbeat query succeeded
16:35:40.713 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
16:35:40.714 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
inFlight=0, closed=false] heartbeat query succeeded
16:35:40.885 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
16:35:40.886 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
inFlight=0, closed=false] heartbeat query succeeded
16:36:10.727 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
16:36:10.729 [cluster1-nio-worker-0] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-1,
inFlight=0, closed=false] heartbeat query succeeded
16:36:10.899 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat
16:36:10.900 [cluster1-nio-worker-1] DEBUG
com.datastax.driver.core.Connection - Connection[127.0.0.1:9042-2,
inFlight=0, closed=false] heartbeat query succeeded
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
Re: Getting NullPointerException during commit into cassandra, after
reconnecting to ignite server
Posted by Ilya Kasnacheev <il...@gmail.com>.
Hello!
I have tried your reproducer, and indeed I observe the same NPE. I will
also update your ticket.
It can even be simplified. It is enough to remove cacheConfigurations
section from client node config (default-config.xml in your case) while
keeping it in server node config to observe this problem reliably.
+ irudyak@
I'm asking the cassandra contributor to chime in. Is it a known limitation
that cacheConfiguration should be set up on all nodes for cassandra-backed
caches?
Indeed PojoField.accessor is transient and it is never populated when it
have to travel over the network.
There's an immediate workaround: you can set clientReconnectDisabled
setting to true, re-create client node manually in case of disconnect.
This way you are guaranteed to have "good" instance of cache store every
time.
Regards,
--
Ilya Kasnacheev
2018-06-14 9:57 GMT+03:00 kotamrajuyashasvi <ko...@gmail.com>:
> Created Ignite ticket for the issue:
> https://issues.apache.org/jira/browse/IGNITE-8788
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>
Re: Getting NullPointerException during commit into cassandra,
after reconnecting to ignite server
Posted by kotamrajuyashasvi <ko...@gmail.com>.
Created Ignite ticket for the issue:
https://issues.apache.org/jira/browse/IGNITE-8788
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/