You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by "Kuku1 (JIRA)" <ji...@apache.org> on 2016/09/10 18:40:21 UTC
[jira] [Comment Edited] (CASSANDRA-12450) CQLSSTableWriter does not
allow Update statement
[ https://issues.apache.org/jira/browse/CASSANDRA-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15480229#comment-15480229 ]
Kuku1 edited comment on CASSANDRA-12450 at 9/10/16 6:40 PM:
------------------------------------------------------------
The error is different now, but you can see it's trying to use the {code}toolInitialization{code} method
Exception in thread "main" java.lang.ExceptionInInitializerError
at de.whatever.BulkCassandraImporter.main(BulkCassandraImporter.java:25)
Caused by: org.apache.cassandra.exceptions.ConfigurationException: Expecting URI in variable: [cassandra.config]. Found[cassandra.yaml]. Please prefix the file with [file:\\\] for local files and [file:\\<server>\] for remote files. If you are executing this from an external tool, it needs to set Config.setClientMode(true) to avoid loading configuration.
at org.apache.cassandra.config.YamlConfigurationLoader.getStorageConfigURL(YamlConfigurationLoader.java:80)
at org.apache.cassandra.config.YamlConfigurationLoader.loadConfig(YamlConfigurationLoader.java:100)
at org.apache.cassandra.config.DatabaseDescriptor.loadConfig(DatabaseDescriptor.java:251)
at org.apache.cassandra.config.DatabaseDescriptor.toolInitialization(DatabaseDescriptor.java:170)
at org.apache.cassandra.io.sstable.CQLSSTableWriter.<clinit>(CQLSSTableWriter.java:101)
... 1 more
was (Author: kuku1):
The error is different now:
Exception in thread "main" java.lang.ExceptionInInitializerError
at de.whatever.BulkCassandraImporter.main(BulkCassandraImporter.java:25)
Caused by: org.apache.cassandra.exceptions.ConfigurationException: Expecting URI in variable: [cassandra.config]. Found[cassandra.yaml]. Please prefix the file with [file:\\\] for local files and [file:\\<server>\] for remote files. If you are executing this from an external tool, it needs to set Config.setClientMode(true) to avoid loading configuration.
at org.apache.cassandra.config.YamlConfigurationLoader.getStorageConfigURL(YamlConfigurationLoader.java:80)
at org.apache.cassandra.config.YamlConfigurationLoader.loadConfig(YamlConfigurationLoader.java:100)
at org.apache.cassandra.config.DatabaseDescriptor.loadConfig(DatabaseDescriptor.java:251)
at org.apache.cassandra.config.DatabaseDescriptor.toolInitialization(DatabaseDescriptor.java:170)
at org.apache.cassandra.io.sstable.CQLSSTableWriter.<clinit>(CQLSSTableWriter.java:101)
... 1 more
> CQLSSTableWriter does not allow Update statement
> ------------------------------------------------
>
> Key: CASSANDRA-12450
> URL: https://issues.apache.org/jira/browse/CASSANDRA-12450
> Project: Cassandra
> Issue Type: Bug
> Components: Streaming and Messaging
> Reporter: Kuku1
> Assignee: Alex Petrov
>
> CQLSSTableWriter throws Exception when trying to use Update statement.
> Has been working fine in previous versions for me.
> Code:
> {code}
> public static void main(String[] args) throws IOException {
> final String KS = "test";
> final String TABLE = "data";
> final String schema = "CREATE TABLE " + KS + "." + TABLE
> + "(k text, c1 text, c2 text, c3 text, v text, primary key(k, c1,c2,c3))";
> final String query = "UPDATE " + KS + "." + TABLE + " SET v = ? WHERE k = ? and c1 = ? and c2 = ? and c3 = ?";
> File dataDir = new File(...);
> CQLSSTableWriter writer = CQLSSTableWriter.builder().inDirectory(dataDir).forTable(schema).using(query).build(); //Exception here (see below)
> HashMap<String, Object> row = new HashMap<>();
> row.put("k", "a");
> row.put("c1", "a");
> row.put("c2", "a");
> row.put("c3", "a");
> row.put("v", "v");
> writer.addRow(row);
> writer.close();
> }
> {code}
> Exception:
> {code}
> 14:51:00.461 [main] INFO o.a.cassandra.cql3.QueryProcessor - Initialized prepar
> ed statement caches with 0 MB (native) and 0 MB (Thrift)
> Exception in thread "main" java.lang.IllegalArgumentException: Invalid query, mu
> st be a INSERT statement but was: class org.apache.cassandra.cql3.statements.Upd
> ateStatement$ParsedUpdate
> at org.apache.cassandra.io.sstable.CQLSSTableWriter.parseStatement(CQLSS
> TableWriter.java:589)
> at org.apache.cassandra.io.sstable.CQLSSTableWriter.access$000(CQLSSTabl
> eWriter.java:102)
> at org.apache.cassandra.io.sstable.CQLSSTableWriter$Builder.using(CQLSST
> ableWriter.java:445)
> at CassandraJsonImporter.main(Cassand
> raJsonImporter.java:66)
> {code}
> I'm currently testing it with 3.7 version, my POM looks like this:
> {code}
> <dependency>
> <groupId>org.apache.cassandra</groupId>
> <artifactId>cassandra-all</artifactId>
> <version>3.7</version>
> </dependency>
> <dependency>
> <groupId>org.apache.cassandra</groupId>
> <artifactId>cassandra-clientutil</artifactId>
> <version>3.7</version>
> </dependency>
> <dependency>
> <groupId>com.datastax.cassandra</groupId>
> <artifactId>cassandra-driver-core</artifactId>
> <version>3.0.0</version>
> </dependency>
> {code}
> It has been working with 3.0.8 versions in the POM, but that version is somehow not including the UDT support?
> I want to use UPDATE instead of INSERT because I need to append data to lists and do not want to overwrite existing data in the lists.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)