flushCommits() is called after adding one Put. Is that intentional ? bq. there are some messages dropped
Did you mean that some Put's were lost after flushing ? Cheers On Fri, Jun 6, 2014 at 4:43 PM, Hotec04 <[email protected]> wrote: > 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. >
