分散キャッシュに 3 つのファイルを配置しようとしています。
以下を使用して、プログラムでそれらの1つを配置します。
DistributedCache.addLocalFiles(conf, "local/path/to/file");
また、-filesオプションを使用して他の 2 つのファイルを配置します。
スタンドアロン モードでローカルに実行すると、すべて正常に動作します。
疑似分散モードで実行しようとすると、このエラーが発生し、その意味がわかりません。私はそれをグーグルで検索しましたが、成功しませんでした。
Distributed cache entry arrays have different lengths
それが何を意味し、どのように解決できるか知っている人はいますか?