a = LOAD '601' using org.apache.hive.hcatalog.pig.HCatLoader();
b = LOAD '602' using org.apache.hive.hcatalog.pig.HCatLoader();
c = LOAD '603' using org.apache.hive.hcatalog.pig.HCatLoader();
d = LOAD 'SKL' using org.apache.hive.hcatalog.pig.HCatLoader();
e = join a by (d_key, c_cd ), b by (d_key, c_cd), c by (p1_key, c_cd), d by (p2_key, c_cd);
Dump e;
========================================================================
如果我在hive中执行相同的连接,我就会得到输出。但在pig中,在dumping e上,它运行mapreduce,读取行,但在成功后不写入输出。但是,如果我在配置单元中通过嵌套的内部连接执行相同的操作,我将得到正确的输出。
谁能给我解释一下Pig在连接关系中不同键的错误吗?
如果我想用hcatlogue(hcatstore)加载到带有动态分区(没有值)的分区空白表中,还有一件事。我得到分区表错误。我不知道hcatalogue出错的原因。如果你面对同样的问题,请向我解释,并提供任何解决方案。
暂无答案!
目前还没有任何答案,快来回答吧!