1

我正在尝试在分布式缓存中放置 3 个文件。

我以编程方式放置其中一个，使用：

  DistributedCache.addLocalFiles(conf, "local/path/to/file");

我还使用该-files选项放置了 2 个其他文件。

在本地运行时，在独立模式下，一切正常。

当试图以伪分布式模式运行它时，我收到了这个错误，我不明白它的含义。我用谷歌搜索但没有成功。

  Distributed cache entry arrays have different lengths

有谁知道这意味着什么以及如何解决？

4

1 回答 1

0

问题源于我添加到缓存本地文件的事实。

相反，我将这些文件移动到 HDFS 并将 HDFS 版本添加到 DistributedCache。有效！

于 2012-09-15T18:44:32.237 回答