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

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

转载作者：IT王子更新时间：2023-10-29 06:10:42

26

4

我从 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));

当尝试执行代码时，我得到了 2,000 条写入 redis 的记录，之后出现了以下错误。

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

如果我遗漏了什么或者是否有更好的方法，请提出建议。

最佳答案

似乎是 RedisIO 中的一个错误，我已经向 Beam 提交了一个问题，并完成了一个 pull request 来修复它。看我猜对了没有。 issues.apache.org/jira/browse/BEAM-5714

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

26

4

0

文章推荐： java - Storm redis spout元组无一异常(exception)地丢失

文章推荐： javascript - react : get custom checkbox's checked attribute

文章推荐： javascript - 正则表达式删除所有重复的字符

ruby - rbenv exec bundle exec 而不仅仅是 bundle exec
我正在尝试设置 rbenv: https://github.com/sstephenson/rbenv#section_2 我有一个问题:我必须在一切之前使用 rbenv exec 所以现在我要做 b
image - OCI 运行时 exec 失败 : exec failed: container_linux. go:349: 启动容器进程导致“exec:
我已经使用我们的应用程序创建了图像，运行该图像后，我可以看到还创建了 docker 容器，当我尝试进入 docker 容器时，出现以下错误，请您在这里帮助我。 """"OCI runtime exec
java - 如何使用 exec :java Instead of exec:exec? 在 Maven 中运行 JMH 基准测试
这post on javapapers.com显示如何运行 JMH通过键入 mvn exec:exec 在 Maven 中进行基准测试。在 Maven 中运行 JMH 非常方便，因为您可以轻松地从 E
linux - `exec n<&0 < file` 和 `exec n
因为我是 shell 脚本的新手，exec命令总是让我感到困惑，同时用 while 探索这个话题循环触发了以下 4 个问题: 下面的语法 1 和 2 有什么区别语法 1: while read LI

exec - 也需要存储重定向到标准输出的 tcl exec 结果
湖一看这两条线案例 1 set cvsUpdStr [exec cvs -qn upd] 案例 2 set cvsUpdStr [exec cvs -qn upd >&@stdout] 对于第一种情
maven - 使用带有参数的 Maven 'exec:exec'
我有一个配置为使用 Maven 构建和运行的项目。该项目取决于平台特定的 native 库，我正在使用发现的策略 here管理这些依赖项。本质上，特定平台的 .dll 或 .so 文件被打包到 ja
exec - tcl exec 先读取标准输出，然后再读取标准错误？
我发现 tcl exec 命令首先从标准输出返回字符串，然后是标准错误。例如，我下面的“测试脚本”按以下顺序生成消息: puts "test started" puts stderr "some no
Docker exec rpc 错误代码 =13 desc = 无效的 header 字段值 "oci runtime error: exec failed: cannot exec a container that has run and stopped\n"
我有 rpc error: code = 13 desc = invalid header field value "oci runtime error: exec failed: cannot ex
exec - 理解 TCL CATCH exec 问题的问题
过去 2 天我遇到了一个问题。我正在运行一个 tcl 脚本(用于 eggdrop)，该脚本在被触发时执行本地 shell 命令(子进程)，如果命令成功，它会输出结果。但是，如果命令不成功，我会收到错
exec - 如何获取 TCL exec 命令的结果(标准输出)？
假设我有一个像这样的 TCL 脚本: exec ls -l 现在这将打印出当前目录的内容。我需要将该输出作为字符串并解析它。我怎么能做到这一点？最佳答案 exec返回输出，因此只需为其设置一个变量:
php - 警告 : exec() [function. exec]:无法在
我正在尝试在 PHP 中使用 GNUPLOT 绘制正弦图，但是当我使用 exec 绘制该图时出现此错误: Warning: exec() [function.exec]: Cannot execute
maven - 如何设置 mvn exec :exec? 的类路径
我正在尝试 mvn exec:exec (或 mvn exec:java )使用类路径中的本地 jar 运行我的程序。但是 jar 无法加载: Exception in thread "main" j
docker exec 或 docker 容器 exec
我在最新的 Docker CLI 文档中注意到 Docker CLI 命令列表已经扩展。如果我使用码头执行早些时候在容器内启动可执行文件现在我也可以使用 docker 容器执行命令。 dock
php - 在执行 PDO::exec() 时调用非对象上的成员函数 exec()
这个问题在这里已经有了答案: Call to a member function exec() on a non-object error in PHP [duplicate] (1 个回答) 关闭
c - 为什么 exec() 函数族不执行 exec() 之后的代码？
手册页说“exec() 系列函数用新的过程镜像替换当前的过程镜像。”但我不太明白“用新过程图像替换当前过程图像”的含义。比如exec成功，perror就达不到 execl("/bin/ls", /*
c - 为什么 exec() 函数族不执行 exec() 之后的代码？
手册页说“exec() 系列函数用新的过程镜像替换当前的过程镜像。”但我不太明白“用新过程图像替换当前过程图像”的含义。比如exec成功，perror就达不到 execl("/bin/ls", /*
linux - find -exec 不运行 exec 部分
我正在 UrbanCode Deploy Shell 步骤中执行以下命令。我想要的是针对找到的所有文件运行 Util.sh。 find . -type f -exec ls -al {} \; fin
java - 在执行 org.codehaus.mojo :exec-maven-plugin:1. 6.0 :exec: java. lang.String 时无法转换为 org.codehaus.mojo.exec.Modulepath
仅当将“-p”添加到 org.codehaus.mojo:exec-maven-plugin:1.6.0:exec 插件时，以下 pom.xml 执行才会失败，删除此参数后它运行正常，但我需要争论，有
java - 始终在目标之前运行生命周期阶段(例如包)(例如 exec :exec)
我正在尝试进入 Maven 并开始编写一个小型库。作为库代码的一部分，我想要一个小型演示 Java 应用程序，可以用来查看库在做什么以及如何使用它。现在真正让我烦恼的一件事是，为了执行该演示，我必须执
java - 通过 "mvn exec:exec"运行class文件
我是 maven 的新手，在通过 maven 运行类文件时遇到问题它运行良好 mvn exec:java -Dexec.mainClass="com.test.Test" 但不是 mvn exec:

首页

博学

6Ren·AI

商城

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