I tried to use dobulkload and below is my code.. I get the error As
17/09/26 20:39:48 WARN mapreduce.LoadIncrementalHFiles: Bulk load operation did not find any files to load in directory /tmp/hfiles1. Does it contain files in subdirectories that correspond to column family names?
17/09/26 20:39:48 INFO client.ConnectionManager$HConnectionImplementation: Closing master protocol: MasterService
17/09/26 20:39:48 INFO client.ConnectionManager$HConnectionImplementation: Closing zookeeper sessionid=0x55e631c17bb08ba
17/09/26 20:39:48 INFO zookeeper.ZooKeeper: Session: 0x55e631c17bb08ba closed
17/09/26 20:39:48 INFO zookeeper.ClientCnxn: EventThread shut down
---------------------------------------
HTable table = new HTable(conf, tableName);
LoadIncrementalHFiles loader = new LoadIncrementalHFiles(
conf);
loader.doBulkLoad(new Path("/tmp/hfiles1"), table);
System.out.print("HFile sent");
ResultScanner scanner = table.getScanner ( "data".getBytes ( ) );
Result next = null;
... View more
