当我将项目从配置单元0.13更新到配置单元1.2时,我创建了一个 HCatMutilTableInputFormat
输入多表到 MapReduce
由 HCatlog
. 在hive 0.13中 createRecordReader
的 inputFormat
我可以得到 TableInfo
从 inputSplit
. 但是版本1.2不能。
下面是我收到的错误消息-
方法 createRecordReader
hcatalog 1.2的 HCatBaseInputFormat
以及 partitionInfo.getTableInfo()
为空。
有人能告诉我为什么吗?能给我拿一下电话吗 tableInfo
从 InputSplit
? 我怎样才能得到它?
这是我的密码-
HCatSplit hcatSplit = InternalUtil.castToHCatSplit(split);
PartInfo partitionInfo = hcatSplit.getPartitionInfo();
// Ensure PartInfo's TableInfo is initialized.
if (partitionInfo.getTableInfo() == null) {
partitionInfo
.setTableInfo(((InputJobInfo) HCatUtil.deserialize(taskContext.getConfiguration().get(HCatConstants.HCAT_KEY_JOB_INFO))).getTableInfo());
}
JobContext jobContext = taskContext;
Configuration conf = jobContext.getConfiguration();
暂无答案!
目前还没有任何答案,快来回答吧!