当前位置: 首页 > 知识库问答 >
问题:

运行数据流时出现问题

殳勇
2023-03-14

我在运行数据流作业时得到以下错误。我正试图将现有的beam版本更新到2.11.0,但在运行时出现了以下错误。

java.lang.incompatibleClassChangeError:类org.apache.beam.model.pipeline.v1.runnerAPI$standardpTransforms$Primitives没有实现在org.apache.beam.runners.core.construction.beam.beam.runners.core.construction.beam.beam.runners.core.construction.premitives上请求的接口com.google.protocolMessageEnum(beamurns.java:27)在sdk.runners.transformHierarchy$node.visit(transformHierarchy.java:666)在org.apache.beam.sdk.runners.transformHierarchy$node.visit(transformHierarchy.java:649)在org.apache.beam.sdk.runners.transformHierarchy$node.visit(transformHierarchy.java:649)在org.apache.beam.sdk.runners.transformHierarchy对于mhierarchy.java:245),在org.apache.beam.sdk.pipeline.traversetopologic(pipeline.java:458),在org.apache.beam.runners.core.construction.unconsumedreads.ensureAllReadsConsumed(unconsumedreads.java:40),在org.apache.beam.runners.dataflowrunner.replaceTransforms(dataflowrunner.java:868),在runner.java:173)在org.apache.beam.sdk.pipeline.run(pipeline.java:313)在org.apache.beam.sdk.pipeline.run(pipeline.java:299)

共有1个答案

太叔志文
2023-03-14

这通常意味着构建Beam时使用的com.google.protobuf:protobuf-java的版本与运行时的版本不匹配。您的管道代码是否也依赖于协议缓冲区?

更新:我已经存档https://issues.apache.org/jira/browse/beam-6839来跟踪这一点。不是意料之中的。

 类似资料:
  • 无法解决以下由)触发的序列化问题。我认为可以解决序列化问题,但事实并非如此。那么,如何使用? 我假设变量和是不可序列化的,但是我如何正确地序列化它们,以便代码能够在集群上工作,而不仅仅是在本地工作呢? 上面显示的代码抛出错误:

  • 问题内容: 我已经将一个Java项目编译到一个Jar文件中,并且在运行它时遇到了问题。 当我跑步时: 我收到以下错误 该类文件不在jar的根目录中,因此我尝试更改主类的路径以使其与该类文件的路径匹配,并且遇到相同的问题。 我应该展平文件结构吗?如果是这样,我该怎么做。如果有任何用途,我正在使用Ant来构建Jar文件。 更新 这是jar的内容以及相关的Ant部分,我将我工作的公司的名称更改为“ or

  • 失败:生成失败,出现异常。 生成在8s中失败cmd:命令失败,退出代码为%1错误输出:failure:生成失败,但出现异常。

  • 我正在尝试使用GPU而不是CPU运行dl4j模型。该模型使用CPU运行良好。所以我决定尝试CUDA来利用我的GPU。我遵循了这里描述的每个步骤,对于CUDA安装,我按照NVIDIA的说明从这里安装CUDA工具包。代码编译正常,但出现错误: 我的项目是使用IntelliJ上的Maven创建的。所有的依赖项都是可以的,否则代码将无法编译。必须缺少某些后端依赖项、库或安装。可能是版本不兼容的问题 消息为

  • 如果我没有使用spring构建图形,那么是否可以使用spring框架完全访问我的neo4j图形?我正在尝试一些示例,但它似乎无法正常工作,因为spring创建的某些元数据不存在。 编辑:例如,我有这个错误当我试图通过它的id访问一个节点时,即