Repository: ignite Updated Branches: refs/heads/ignite-6252 [created] 13cf04e79
IGNITE-6252 Cassandra Cache Store Session does not retry if statement failed This patch will check to ensure that we retry any prepare statement failure when we submit the async request to Cassandra Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/37620be6 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/37620be6 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/37620be6 Branch: refs/heads/ignite-6252 Commit: 37620be67fc9d882892964516c983efef1c34415 Parents: 86bd544 Author: sunnychanwork <[email protected]> Authored: Mon Sep 4 17:43:28 2017 +0800 Committer: GitHub <[email protected]> Committed: Mon Sep 4 17:43:28 2017 +0800 ---------------------------------------------------------------------- .../cache/store/cassandra/session/CassandraSessionImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/37620be6/modules/cassandra/store/src/main/java/org/apache/ignite/cache/store/cassandra/session/CassandraSessionImpl.java ---------------------------------------------------------------------- diff --git a/modules/cassandra/store/src/main/java/org/apache/ignite/cache/store/cassandra/session/CassandraSessionImpl.java b/modules/cassandra/store/src/main/java/org/apache/ignite/cache/store/cassandra/session/CassandraSessionImpl.java index 19b88c9..b2e5298 100644 --- a/modules/cassandra/store/src/main/java/org/apache/ignite/cache/store/cassandra/session/CassandraSessionImpl.java +++ b/modules/cassandra/store/src/main/java/org/apache/ignite/cache/store/cassandra/session/CassandraSessionImpl.java @@ -304,10 +304,10 @@ public class CassandraSessionImpl implements CassandraSession { throw new IgniteException(errorMsg, unknownEx); // If there are no errors occurred it means that operation successfully completed and we can return. - if (tblAbsenceEx == null && hostsAvailEx == null && prepStatEx == null) + if (tblAbsenceEx == null && hostsAvailEx == null && prepStatEx == null && error!=null) return assistant.processedData(); - if (tblAbsenceEx != null) { + if (tblAbsenceEx != null && CassandraHelper.isTableAbsenceError(error)) { // If there are table absence error and it is not required for the operation we can return. if (!assistant.tableExistenceRequired()) return assistant.processedData();
