If you haven't seen any exceptions during the execution I would suggest to check for duplicated rowkeys. If it's not possible to do for the source, you may try to do it for HBase table itself. I would recommend to use ruby function in HBase shell: def count_versions(tablename, num, args = {})
table = @shell.hbase_table(tablename)
# Run the scanner
scanner = table._get_scanner(args)
count = 0
iter = scanner.iterator
# Iterate results
while iter.hasNext
row = iter.next
i = row.listCells.count
if i > num
count += 1
end
end
# Return the counter
return count
end and execute in in the way: count_versions 'X', 10, {RAW =>true, VERSIONS=>3} where 10 is the expected number of cells for each row which depends on your data schema. So if the regular row has 10 cells, the one that was overwritten will have 20. Function will return the number of such rows.
... View more
