hcatalog 1.2 createrecordreader partinfo的tableinfo为空

chy5wohz  于 2021-06-29  发布在  Hive
关注(0)|答案(0)|浏览(148)

当我将项目从配置单元0.13更新到配置单元1.2时,我创建了一个 HCatMutilTableInputFormat 输入多表到 MapReduceHCatlog . 在hive 0.13中 createRecordReaderinputFormat 我可以得到 TableInfoinputSplit . 但是版本1.2不能。
下面是我收到的错误消息-
方法 createRecordReader hcatalog 1.2的 HCatBaseInputFormat 以及 partitionInfo.getTableInfo() 为空。
有人能告诉我为什么吗?能给我拿一下电话吗 tableInfoInputSplit ? 我怎样才能得到它?
这是我的密码-

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();

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题