[jira] [Comment Edited] (CASSANDRA-9449) Running ALTER TABLE cql statement asynchronously results in failure

["Paul Praet (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/CASSANDRA-9449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14555793#comment-14555793 ] 

Paul Praet edited comment on CASSANDRA-9449 at 5/22/15 11:18 AM:
-----------------------------------------------------------------

1) Yes:
{code}
cqlsh> DESCRIBE TABLE wifidoctor.device;

CREATE TABLE wifidoctor.device (
    columna text,
    columnb text,
    columnc timestamp,
    columnd text,
    columne text,
    columnf text,
    columng text,
    columnh text,
    PRIMARY KEY ((columna, columnb))
) WITH bloom_filter_fp_chance = 0.01
    AND caching = '{"keys":"ALL", "rows_per_partition":"NONE"}'
    AND comment = ''
    AND compaction = {'min_threshold': '4', 'class': 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy', 'max_threshold': '32'}
    AND compression = {'sstable_compression': 'org.apache.cassandra.io.compress.LZ4Compressor'}
    AND dclocal_read_repair_chance = 0.1
    AND default_time_to_live = 0
    AND gc_grace_seconds = 864000
    AND max_index_interval = 2048
    AND memtable_flush_period_in_ms = 0
    AND min_index_interval = 128
    AND read_repair_chance = 0.0
    AND speculative_retry = '99.0PERCENTILE';

cqlsh> INSERT INTO wifidoctor.device (columnA, columnB, columnC,columnD,columnE,columnF,columnG,columnH) VALUES ('a','','2015-01-01','','','','','');
InvalidRequest: code=2200 [Invalid query] message="Unknown identifier columne"

{code}

2) yes, it does. After the restart, the INSERT query works.


was (Author: praetp):
1) Yes:
{code}
CREATE TABLE wifidoctor.device (
    columna text,
    columnb text,
    columnc timestamp,
    columnd text,
    columne text,
    columnf text,
    columng text,
    columnh text,
    PRIMARY KEY ((columna, columnb))
) WITH bloom_filter_fp_chance = 0.01
    AND caching = '{"keys":"ALL", "rows_per_partition":"NONE"}'
    AND comment = ''
    AND compaction = {'min_threshold': '4', 'class': 'org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy', 'max_threshold': '32'}
    AND compression = {'sstable_compression': 'org.apache.cassandra.io.compress.LZ4Compressor'}
    AND dclocal_read_repair_chance = 0.1
    AND default_time_to_live = 0
    AND gc_grace_seconds = 864000
    AND max_index_interval = 2048
    AND memtable_flush_period_in_ms = 0
    AND min_index_interval = 128
    AND read_repair_chance = 0.0
    AND speculative_retry = '99.0PERCENTILE';

cqlsh> INSERT INTO wifidoctor.device (columnA, columnB, columnC,columnD,columnE,columnF,columnG,columnH) VALUES ('a','','2015-01-01','','','','','');
InvalidRequest: code=2200 [Invalid query] message="Unknown identifier columne"

{code}

2) yes, it does. After the restart, the INSERT query works.

> Running ALTER TABLE cql statement asynchronously results in failure
> -------------------------------------------------------------------
>
>                 Key: CASSANDRA-9449
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-9449
>             Project: Cassandra
>          Issue Type: Bug
>         Environment: Singe cluster environment
>            Reporter: Paul Praet
>
> When running 'ALTER TABLE' cql statements asynchronously, we notice that often certain columns are missing, causing subsequent queries to fail.
> The code snippet below can be used to reproduce the problem.
> cassandra is a com.datastax.driver.core.Session reference.
> We construct the table synchronously and then alter it (adding five columns) with the cassandra async API. We synchronize to ensure the table is properly altered before continuing. Preparing the statement at the bottom of the code snippet often fails:
> {noformat} com.datastax.driver.core.exceptions.InvalidQueryException: Unknown identifier columnf {noformat}
> {code}
>  @Test
>     public void testCassandraAsyncAlterTable() throws Exception {
>         ResultSet rs = cassandra.execute("CREATE TABLE device ( columnA text, columnB text, columnC timestamp, PRIMARY KEY ((columnA, columnB)));");
>         List<ResultSetFuture> futures = new ArrayList<>();
>         futures.add(cassandra.executeAsync("ALTER TABLE device ADD columnD text;"));
>         futures.add(cassandra.executeAsync("ALTER TABLE device ADD columnE text;"));
>         futures.add(cassandra.executeAsync("ALTER TABLE device ADD columnF text;"));
>         futures.add(cassandra.executeAsync("ALTER TABLE device ADD columnG text;"));
>         futures.add(cassandra.executeAsync("ALTER TABLE device ADD columnH text;"));
>         for(ResultSetFuture resultfuture : futures){ resultfuture.get(); }
>           
>         /* discard the result; only interested to see if it works or not */
>         cassandra.prepare("INSERT INTO device (columnA, columnB, columnC,columnD,columnE,columnF,columnG,columnH) VALUES (?,?,?,?,?,?,?,?);");
>     }
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)