source: class TestMapReduceExecutor {
  
      private static final String RESOURCES_PATH;
      private EmbulkEmbed embulk;
      private ConfigLoader configLoader;
      private Random random;
  
      @Test
      public void testInvalidReducers()
              throws Exception
      {
  
target:         try {
              ConfigSource config = loadConfigSource(configLoader, "config/embulk_mapred_invalid_reducers_config.yml")
                      .merge(configLoader.newConfigSource().set("exec", ImmutableMap.of("type", getPluginName())));
              embulk.run(config);
              fail();
          }
          catch (Throwable t) {
              assertTrue(t instanceof PartialExecutionException);
              assertTrue(t.getCause() instanceof ConfigException);
          }
      }
  
  }