Получение 'ERR EXEC без MULTI' при использовании RedisIO из Apache Beam API.

Question

Я читаю данные из BigQuery и пишу в Redis, используя RedisIO из Apache Beam API.Ниже приведен фрагмент кода.

pipeline.apply("Read Data From BigQuery",
        BigQueryIO.readTableRows().withoutValidation()
            .fromQuery(""))
    .apply("Convert Table rows into Redis Entity",
        ParDo.of(new RedisEntity()))
    .apply("Write to Redis",
        RedisIO.write().withEndpoint("localhost", 6379));

При попытке выполнить код я получаю 2000 записей, написанных в redis, и после этого получаю сообщение об ошибке ниже.

redis.clients.jedis.exceptions.JedisDataException: EXEC без MULTI в redis.clients.jedis.Pipeline.exec (Pipeline.java:139) в org.apache.beam.sdk.io.redis.RedisIO $ Write $ WriteFn.processElement (RedisIO.java:419)

Добрый совет, если я что-то упустил или есть лучший способ сделать это.

Answer 1

Выглядит как ошибка в RedisIO, я отправил проблему в Beam и сделал запрос на ее устранение. Посмотрим, правильно ли я это угадаю. вопроса.apache.org/jira/browse/BEAM-5714