You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ak...@apache.org on 2015/11/12 09:01:05 UTC
ignite git commit: IGNITE-1753 Debug NPE in benchmarks.
Repository: ignite
Updated Branches:
refs/heads/ignite-1753-1282 397ccfa9c -> cf8ac9696
IGNITE-1753 Debug NPE in benchmarks.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/cf8ac969
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/cf8ac969
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/cf8ac969
Branch: refs/heads/ignite-1753-1282
Commit: cf8ac9696eb2b843639ebde574e27b20d1adbbf9
Parents: 397ccfa
Author: Alexey Kuznetsov <ak...@apache.org>
Authored: Thu Nov 12 15:01:20 2015 +0700
Committer: Alexey Kuznetsov <ak...@apache.org>
Committed: Thu Nov 12 15:01:20 2015 +0700
----------------------------------------------------------------------
.../apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java | 4 ++++
.../cache/distributed/near/GridNearTxFinishFuture.java | 2 ++
2 files changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/cf8ac969/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
index ca69cf7..00b6518 100644
--- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
+++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java
@@ -328,6 +328,8 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K, V>,
* @throws SQLException In case of error.
*/
protected Connection connection() throws SQLException {
+ log.debug("Open connection");
+
CacheStoreSession ses = session();
if (ses.transaction() != null) {
@@ -376,6 +378,8 @@ public abstract class CacheAbstractJdbcStore<K, V> implements CacheStore<K, V>,
/** {@inheritDoc} */
@Override public void sessionEnd(boolean commit) throws CacheWriterException {
+ log.debug("sessionEnd: " + commit);
+
CacheStoreSession ses = session();
Transaction tx = ses.transaction();
http://git-wip-us.apache.org/repos/asf/ignite/blob/cf8ac969/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java
index 46c9f3e..99bc440 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java
@@ -179,6 +179,8 @@ public final class GridNearTxFinishFuture<K, V> extends GridCompoundIdentityFutu
* @param e Error.
*/
void onError(Throwable e) {
+ log.debug("onError: " + e.getMessage());
+
tx.commitError(e);
if (err.compareAndSet(null, e)) {