Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

can not read correct value when insert frequently #70

Open
wzqaustin opened this issue Jul 11, 2014 · 0 comments
Open

can not read correct value when insert frequently #70

wzqaustin opened this issue Jul 11, 2014 · 0 comments

Comments

@wzqaustin
Copy link

hi, guys
I can not read correct value when insert frequently with pelops-1.3-1.1.x, test with cassandra 1.2.17 and 2.0.8. cluster has only one node。
Code:
package com.cnsuning.bigdata.storm.exhibition;

import org.apache.cassandra.thrift.Column;
import org.apache.cassandra.thrift.ConsistencyLevel;
import org.scale7.cassandra.pelops.Cluster;
import org.scale7.cassandra.pelops.Mutator;
import org.scale7.cassandra.pelops.Pelops;
import org.scale7.cassandra.pelops.Selector;

public class Test {
public static void main(String arg[]) throws InterruptedException {

    Cluster cluster = new Cluster("10.27.35.128",9160);
    Pelops.addPool("test-pool",cluster,"mykeyspace");
    Selector selector = Pelops.createSelector("test-pool");
    Mutator mutator = Pelops.createMutator("test-pool");

    String cassandraOutputCF = "cf1";

    int count = 0;
    for( int i = 0 ; i < 100; i++) {
        count += 1;
        mutator.writeColumn(cassandraOutputCF, "rowkey1", 
            mutator.newColumn("count", Integer.toString(count)));
        mutator.execute(ConsistencyLevel.ALL);
        System.out.println("insert count=" + count);
        Thread.sleep(50);

        Column col = selector.getColumnFromRow(cassandraOutputCF, 
                "rowkey1", "count", ConsistencyLevel.ALL);
        System.out.println("read count=" + new String(col.getValue()));
    }
}

}

result:
insert count=1
read count=1
insert count=2
read count=2
insert count=3
read count=3
insert count=4
read count=4
insert count=5
read count=5
insert count=6
read count=6
insert count=7
read count=7
insert count=8
read count=8
insert count=9
read count=9
insert count=10
read count=9
insert count=11
read count=9
insert count=12
read count=9
insert count=13
read count=9
insert count=14
read count=9
insert count=15
read count=9
insert count=16
read count=9
insert count=17
read count=9
insert count=18
read count=9
insert count=19
read count=9
insert count=20
read count=9
insert count=21
read count=9
insert count=22
read count=9
insert count=23
read count=9
insert count=24
read count=9
insert count=25
read count=9
insert count=26
read count=9
insert count=27
read count=9
insert count=28
read count=9
insert count=29
read count=9
insert count=30
read count=9
insert count=31
read count=9
insert count=32
read count=9
insert count=33
read count=9
insert count=34
read count=9
insert count=35
read count=9
insert count=36
read count=9
insert count=37
read count=9
insert count=38
read count=9
insert count=39
read count=9
insert count=40
read count=9
insert count=41
read count=9
insert count=42
read count=9
insert count=43
read count=9
insert count=44
read count=9
insert count=45
read count=9
insert count=46
read count=9
insert count=47
read count=9
insert count=48
read count=9
insert count=49
read count=9
insert count=50
read count=9
insert count=51
read count=9
insert count=52
read count=9
insert count=53
read count=9
insert count=54
read count=9
insert count=55
read count=9
insert count=56
read count=9
insert count=57
read count=9
insert count=58
read count=9
insert count=59
read count=9
insert count=60
read count=9
insert count=61
read count=9
insert count=62
read count=9
insert count=63
read count=9
insert count=64
read count=9
insert count=65
read count=9
insert count=66
read count=9
insert count=67
read count=9
insert count=68
read count=9
insert count=69
read count=9
insert count=70
read count=9
insert count=71
read count=9
insert count=72
read count=9
insert count=73
read count=9
insert count=74
read count=9
insert count=75
read count=9
insert count=76
read count=9
insert count=77
read count=9
insert count=78
read count=9
insert count=79
read count=9
insert count=80
read count=9
insert count=81
read count=9
insert count=82
read count=9
insert count=83
read count=9
insert count=84
read count=9
insert count=85
read count=9
insert count=86
read count=9
insert count=87
read count=9
insert count=88
read count=9
insert count=89
read count=9
insert count=90
read count=90
insert count=91
read count=91
insert count=92
read count=92
insert count=93
read count=93
insert count=94
read count=94
insert count=95
read count=95
insert count=96
read count=96
insert count=97
read count=97
insert count=98
read count=98
insert count=99
read count=99
insert count=100
read count=99

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant