我目前在 Hadoop 中以伪分布式模式工作。我的 reduce 函数的工作方式是:对于每个键,它将创建一个其值的数组列表,然后将创建一个单例类的实例 [该类存在于库中,因此我无法更改它]。然后它调用此实例的方法。
现在我的问题是:假设 map 函数发出 2 个键,那么 reducer 只会为另一个键处理一个键,它会说“Java.lang.exception”类[单例]无法实例化。
我担心的是为什么会这样?在伪分布式模式下,每个 reducer 运行不同的 JVM!
我目前在 Hadoop 中以伪分布式模式工作。我的 reduce 函数的工作方式是:对于每个键,它将创建一个其值的数组列表,然后将创建一个单例类的实例 [该类存在于库中,因此我无法更改它]。然后它调用此实例的方法。
现在我的问题是:假设 map 函数发出 2 个键,那么 reducer 只会为另一个键处理一个键,它会说“Java.lang.exception”类[单例]无法实例化。
我担心的是为什么会这样?在伪分布式模式下,每个 reducer 运行不同的 JVM!