diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableOutputFormat.java hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableOutputFormat.java index dd72939..18b54da 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableOutputFormat.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/mapred/TableOutputFormat.java @@ -53,7 +53,7 @@ public class TableOutputFormat extends FileOutputFormat { private BufferedMutator m_mutator; - + private Connection connection; /** * Instantiate a TableRecordWriter with the HBase HClient for writing. Assumes control over the * lifecycle of {@code conn}. @@ -62,8 +62,19 @@ public class TableOutputFormat extends FileOutputFormat