Hadoop singleton pattern uasge

Question

Я пытаюсь реализовать singleton, который собирается кэшировать и проверять конфигурацию карты, уменьшая задания в hadoop. Назовите его ConfigurationManager.

Вот что у меня есть на данный момент:

public class ConfigurationManager { 
    private static volatile ConfigurationManager instance; 
    private static final String CONF_NAME = "isSomethingEnabled"; 
    private boolean isSomethingEnabled; 

    private ConfigurationManager(Configuration configuration) { 
     this.isSomethingEnabled= configuration.getBoolean(CONF_NAME, false); 
    } 

    public static void init(Configuration configuration) { 
     if (instance == null) { 
      synchronized (ConfigurationManager.class) { 
       if (instance == null) { 
        this.instance = new ConfigurationManager(configuration); 
       } 
      } 
     } 
    } 

    public static ConfigurationManager get() { 
     return instance; 
    } 

    public boolean isSomethingEnabled() { 
     return isSomethingEnabled; 
    } 
} 

Как вы можете видеть, что это предназначено, чтобы быть потокобезопасным. Кроме того, он не является стандартным одноэлементным: я разделял инициализацию и методы доступа, чтобы не применять присутствие экземпляра hadoop Configuration на вызове get. Поэтому, чтобы использовать его, я преждевременно вызываю у предка Tool, а затем пытаюсь получить доступ к моему синглтону, используя get в редукторах (например, ConfigurationManager.get().isSomethingEnabled()), но по некоторым причинам get возвращает null. Может ли кто-нибудь объяснить, пожалуйста, такое поведение? Может быть, карты/редукторы инициируются как отдельные процессы?

Answer 1

Каждая задача сокращения выполняется на другом jvm. Который объяснил бы null.

Вы можете сделать это за уменьшить задачу: Reducer - configure