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-10639 Commit: 84a8e8108f973719f1f05e41818ec3ac93312d1b Parents: 0eb5bcc Author: Venky Kandaswamy <[email protected]> Authored: Tue Dec 18 10:54:36 2018 +0700 Committer: Alexey Kuznetsov <[email protected]> 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;
