How did it work?
My design is like this:
each thread will call the write method, in the write method, the first
statement is creating the table like:
table = connection.getTable(this.tableName);
then I set auto flush to false
then I put the table.put statement in a synchronized block like this:
synchronized(this){
Put p = config.addRow(rowKey, value);
table.put(p);
table.flushCommits();
}
There is no error in this mode but there are some messages dropped while
flush the table.
Thank you!
--
View this message in context:
http://apache-hbase.679495.n3.nabble.com/Discuss-HBase-with-multiple-threads-tp4060081p4060094.html
Sent from the HBase User mailing list archive at Nabble.com.
