redis - 从Apache Beam API使用RedisIO时获取 'ERR EXEC without MULTI'。

我正在从BigQuery读取数据，并使用来自Apache Beam API的RedisIO写入Redis。下面是代码片段。

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编写的记录，此后出现以下错误。



如果我缺少某些东西，或者有更好的方法，请提供建议。

最佳答案

似乎是RedisIO中的错误，我已经向Beam提交了一个问题，并提出了拉取请求以对其进行修复。看看我是否猜对了。 issues.apache.org/jira/browse/BEAM-5714

关于redis - 从Apache Beam API使用RedisIO时获取 'ERR EXEC without MULTI'。，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/52265777/