You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2018/12/19 20:24:36 UTC
[13/52] [abbrv] ignite git commit: IGNITE-4890 Support Cassandra
message 'unconfigured columnfamily'. Fixes #1719.
IGNITE-4890 Support Cassandra message 'unconfigured columnfamily'. Fixes #1719.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/84a8e810
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/84a8e810
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/84a8e810
Branch: refs/heads/ignite-627
Commit: 84a8e8108f973719f1f05e41818ec3ac93312d1b
Parents: 0eb5bcc
Author: Venky Kandaswamy <vk...@172.28.88.26>
Authored: Tue Dec 18 10:54:36 2018 +0700
Committer: Alexey Kuznetsov <ak...@apache.org>
Committed: Tue Dec 18 10:54:36 2018 +0700
----------------------------------------------------------------------
.../ignite/cache/store/cassandra/common/CassandraHelper.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/84a8e810/modules/cassandra/store/src/main/java/org/apache/ignite/cache/store/cassandra/common/CassandraHelper.java
----------------------------------------------------------------------
diff --git a/modules/cassandra/store/src/main/java/org/apache/ignite/cache/store/cassandra/common/CassandraHelper.java b/modules/cassandra/store/src/main/java/org/apache/ignite/cache/store/cassandra/common/CassandraHelper.java
index 9492cec..c3981b3 100644
--- a/modules/cassandra/store/src/main/java/org/apache/ignite/cache/store/cassandra/common/CassandraHelper.java
+++ b/modules/cassandra/store/src/main/java/org/apache/ignite/cache/store/cassandra/common/CassandraHelper.java
@@ -49,6 +49,9 @@ public class CassandraHelper {
/** Cassandra error message if specified table doesn't exist. */
private static final String TABLE_EXIST_ERROR2 = "Error preparing query, got ERROR INVALID: unconfigured table";
+
+ /** Cassandra error message if specified table doesn't exist. */
+ private static final Pattern TABLE_EXIST_ERROR3 = Pattern.compile("unconfigured columnfamily [0-9a-zA-Z_]+");
/** Cassandra error message if trying to use prepared statement created from another session. */
private static final String PREP_STATEMENT_CLUSTER_INSTANCE_ERROR = "You may have used a PreparedStatement that " +
@@ -97,6 +100,7 @@ public class CassandraHelper {
while (e != null) {
if (e instanceof InvalidQueryException &&
(TABLE_EXIST_ERROR1.matcher(e.getMessage()).matches() ||
+ TABLE_EXIST_ERROR3.matcher(e.getMessage()).matches() ||
KEYSPACE_EXIST_ERROR1.matcher(e.getMessage()).matches() ||
KEYSPACE_EXIST_ERROR2.matcher(e.getMessage()).matches()))
return true;