async.map没有't使用嵌套瀑布调用cb

我在异步方面遇到了一些问题。

这是我的代码：

Main.prototype._onlyGeoLinks = function() {
  var redis = RedisClient.client
    , getKeys = function(key, cb) {
      redis.keys(key, cb);
    }
    , count = 0
  //
  cb = null;
  async.waterfall([
    function(cb) {
      async.concat([
        'events:*'
        , 'news:*:*:*:*'
        , 'deals:*'
      ], getKeys, cb);
    },
    function(keys, cb) {
      // iterate keys
      async.map(keys, function(key, cb) {
        async.waterfall([
          function(cb) {
            redis.get(key, cb);
          }, function(item, cb) {
            log.verbose(LOG_CTX, 'Parsing item.. %d', ++count);
            GeoHelper.parse(item, cb); // This are calling cb(new Error('bla'))
          }
        ], cb) // at this point, I can read err
      }, cb) // This is never called
    }
  ], function(err, items) {
    if (err) {
      log.error(LOG_CTX, err);
    } else {
      log.verbose(LOG_CTX, items);
      log.verbose(LOG_CTX, items.length);
    }
  })
}

我尝试过的

async.map(keys, function(key, cb) {
    async.waterfall([
      function(cb) {
        redis.get(key, cb);
      }, function(item, cb) {
        log.verbose(LOG_CTX, 'Parsing item.. %d', ++count);
        GeoHelper.parse(item, cb);
      }
    ], function(err) {
      log.error('1', err);  // This prints ERR
      cb(err);
    })
  }, function(err) {
    log.error('2', err);  // this is never called
    cb(err);
  })

我错过了什么？谢谢你的帮助。