-
Notifications
You must be signed in to change notification settings - Fork 29
Description
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