diff --git a/core/src/main/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java b/core/src/main/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java index edbaefa..717ba6a 100644 --- a/core/src/main/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java +++ b/core/src/main/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java @@ -159,6 +159,8 @@ public class HCatOutputFormat extends HCatBaseOutputFormat { outputJobInfo.setPartitionValues(valueMap); } + // To get around hbase failure on single node, see BUG-4383 + conf.set("dfs.client.read.shortcircuit", "false"); HCatSchema tableSchema = HCatUtil.extractSchema(table); StorerInfo storerInfo = InternalUtil.extractStorerInfo(table.getTTable().getSd(), table.getParameters());