基本上在我的FlowDef中,我想用我將通過API讀取的其他元組與我的元組進行連接。所以我創建了另一個空管道,並使用函數從API中填充元組。然後我做一個CoGroup並將其用作尾管。 Tap tap1 = new Hfs();
Pipe pipe1 = new Pipe("pipe1");
Pipe pipeFromApi = new Pipe("pipeFromApi");
Pipe j
我在Hadoop作業中發現以下異常。我無法弄清楚這個例外的原因。你能幫我解決這個錯誤嗎?爲什麼我們會得到這個錯誤? 異常堆棧跟蹤: org.apache.hadoop.fs.BlockMissingException: Could not obtain block: blk_6488469967470272993_1110 file=/media/ephemeral0/hadoop-root/56