Loading [MathJax]/jax/output/CommonHTML/config.js

社区首页 >问答首页 >运行数据流时发出

问运行数据流时发出
EN

Stack Overflow用户

提问于 2019-03-13 08:21:28

回答 3查看 1.6K关注 0票数 4

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

org.apache.beam.model.pipeline.v1.RunnerApi$StandardPTransforms$Primitives类没有实现请求的接口com.google.protobuf.ProtocolMessageEnum在org.apache.beam.runners.core.construction.BeamUrns.getUrn(BeamUrns.java:27) at org.apache.beam.runners.core.construction.PTransformTranslation.(PTransformTranslation.java:58) at org.apache.beam.runners.core.construction.UnconsumedReads$1.visitValue(UnconsumedReads.java:49) at org.apache。beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:666) at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:649) at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:649) at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:649) at org.apache.beam.sdk.runners.TransformHierarchy$Node.access$600(TransformHierarchy.java:311) at org.apache.beam.sdk.runners.TransformHierarchy.visit(TransformHierarchy.java:245) at org.apache.beam.sdk.Pipeline.traverseTopologically(Pipeline.java:458) at org.apache.beam.runners.core.construction.UnconsumedReads.ensureAllReadsConsumed(UnconsumedReads.java:40) at org.apache.beam.runners.dataflow.DataflowRunner.replaceTransforms(DataflowRunner.java:868) at org.apache.beam.runners.dataflow.DataflowRunner.run(DataflowRunner.java:660) at org.apache.beam.runners.dataflow.DataflowRunner.run(DataflowRunner.java:173) at org.apache.beam.sdk.Pipeline.run(Pipeline.java:313) at org.apache.beam.sdk.Pipeline.run(Pipeline.java:299)

google-cloud-dataflow

EN

回答 3

Stack Overflow用户

发布于 2019-03-14 12:01:41

这通常意味着Beam所用的com.google.protobuf:protobuf-java版本在运行时与版本不匹配。管道代码也依赖于协议缓冲区吗？

更新:我已经注册了https://issues.apache.org/jira/browse/BEAM-6839来跟踪这个。这是预料不到的。

票数 1

EN

Stack Overflow用户

发布于 2020-06-09 10:40:43

我没有足够的代表留下评论，但我遇到了这个问题，后来发现我的问题是，我的pom.xml有不同的波束版本。有的有2.19，有的有2.20。

我会在pom或gradle文件中快速搜索您的版本，以确保它们都是相同的。

票数 1

EN

Stack Overflow用户

发布于 2020-07-06 17:36:18

这可能是由于不兼容的依赖关系造成的。通过同时升级依赖项，我成功地将beam从2.2.0升级到2.20.0。

beam.version: 2.20.0
guava.version: 29.0-jre
bigquery.version: v2-rev20191211-1.30.9
google-api-client.version: 1.30.9
google-http-client.version: 1.34.0
pubsub.version: v1-rev20200312-1.30.9

票数 1

EN

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/55146663

复制

相关文章

Spring Cloud Task 核心组件-Task Application

Spring Cloud Task是Spring Cloud生态系统中的一个重要组件，用于支持有状态的短暂任务的开发和执行。

堕落飞鸟

2023/04/16

6111

Spring Cloud Task 核心组件-Task Repository

Spring Cloud Task是一个用于构建简单任务的框架。它提供了Task Application、Task Launcher和Task Repository三个核心组件，分别用于定义和执行任务、启动和管理任务、以及存储任务相关的元数据和状态信息。其中，Task Repository是Spring Cloud Task的核心组件之一，它负责管理和存储任务相关的数据。

堕落飞鸟

2023/04/16

2880

【C# 基础精讲】Task和Task＜T＞的应用

c#task 基础异步异常

当涉及异步编程时，Task 和 Task<T> 是C#中的重要概念。它们不仅是处理异步操作的关键类型，还提供了一些强大的功能和方法，使异步编程更加高效和灵活。在本文中，我们将深入探讨 Task 和 Task<T> 的应用，从创建、执行、等待到取消和异常处理等方面进行详细讨论，帮助您更好地理解如何在C#中应用这些类型。

繁依Fanyi

2023/10/12

7310

【C# 基础精讲】Task和Task＜T＞的应用

Spring Cloud Task 核心组件-Task Launcher

Spring Cloud Task是一个用于快速创建和执行短暂任务的框架。Task Launcher是Spring Cloud Task的另一个核心组件，它可以帮助我们在多个环境中部署和执行Task Application。

堕落飞鸟

2023/04/16

7941

Spring Cloud Task 核心组件-Task Explorer

在使用Spring Cloud Task时，我们通常需要查看已经执行的任务以及任务的执行状态等信息。而Task Explorer正是为我们提供了这些信息的组件。

堕落飞鸟

2023/04/16

5610

Spring Cloud Task 核心组件-Task Execution Listener

Spring Cloud Task是一个用于构建简单任务的框架。它提供了Task Application、Task Launcher、Task Repository等多个核心组件，分别用于定义和执行任务、启动和管理任务、以及存储任务相关的元数据和状态信息。其中，Task Execution Listener是Spring Cloud Task的核心组件之一，它用于监控和管理任务的执行过程。

堕落飞鸟

2023/04/16

6301

C++核心准则T.65:使用标签分发提供函数的不同实现

T.65: Use tag dispatch to provide alternative implementations of a function

面向对象思考

2020/09/21

1K0

C++核心准则T.64：使用特化提供类模板的不同实现

class interface templates 接口

T.64: Use specialization to provide alternative implementations of class templates

面向对象思考

2020/09/21

6740

Task和backStack（本篇章核心）

java 编程算法腾讯云测试服务

摘要总结：通过分析Task和backStack的关系，可以得出一个task内可以有多个Activity，一个Task也可以对应多个Process。同时，通过adb shell dumpsys activity命令可以观察到，一个Task内的Activity可以属于同一个App，也可以属于不同的App。通过学习源码，可以发现，在ActivityManagerService中，Task被封装成TaskRecord对象，每个Task对应一个TaskStack，每个TaskStack包含一个mHistory Stack。在mHistory Stack中，每个元素都是一个ActivityRecord对象，ActivityRecord对象通过TaskRecord与对应的Task关联，通过Activity info与对应的Activity关联。同时，同一个Task内的ActivityRecord在mHistory中会按照先入先出的顺序进行排序。

梦里茶

2017/12/29

5740

Task和backStack（本篇章核心）

T-SQL取时间的不同方法

超级实用的T-SQL取时间的不同方法 CONVERT(nvarchar(10),count_time,121): CONVERT为日期转换函数，一般就是在时间类型 (datetime,smalldatetime)与字符串类型(nchar,nvarchar,char,varchar)相互转换的时候才用到的函数的3个参数，第1个参数为，转换后的大小，第2个为转换日期的字段或函数，第3个为转换的格式，具体如下： 0 | 0 or 100 | mon dd yyyy hh:miAM(或PM) 1 | 101 |

用户1719978

2018/07/05

5970

T24银行核心业务系统

https http java 网络安全

http://www.pianshen.com/article/8248107255/

全栈程序员站长

2022/09/20

1.2K0

通过JavaScript实现HTTP到HTTPS的强制跳转 By HKL,

https http 网络安全

最近通过一些在线文件云空间测试云存储部署静态网站遇到HTTP到HTTPS的强制跳转的问题，平时通过nginx配置是比较简单实现的，但是例如七牛云虽然可以设置HTTPS访问，但是不支持设置HTTP到HTTPS的强制跳转，解决方法可以是先通过设置HSTS，通过浏览器级的强制跳转实现，但是本方法只能在webkit内核的浏览器上生效，而且由一定的时间差，所以最后寻找到通过前端JavaScript脚本实现HTTP到HTTPS的强制跳转，代码如下

hiplon

2020/07/22

1.8K0

阻塞队列的核心方法&对阻塞的不同处理

编程算法其他

阻塞队列，顾名思义，首先它是一个队列，而一个阻塞队列在数据结构中所起的作用大致如下图所示：

名字是乱打的

2022/05/13

6920

阻塞队列的核心方法&对阻塞的不同处理

从T+1到T+0，浅谈PetaBase的实时流式处理

数据库 sql windows 日志数据大数据

随着互联网+的进一步发展，各行业对大数据技术的应用日趋成熟，企业的信息化范围正在高速扩展。

数据狗忙忙忙

2019/08/13

2.5K0

从T+1到T+0，浅谈PetaBase的实时流式处理

【leetcode刷题】T156-不同路径

编程算法机器人

https://leetcode-cn.com/problems/unique-paths/

木又AI帮

2019/09/03

2940

PHP实现根据请求的域名跳转到不同目录 By HKL, T

php 网站 com 虚拟主机域名

使用一些PHP虚拟主机的时候，多个域名绑定到同一空间下，但是希望不同域名能通过不同目录实现访问不同网站的效果：

hiplon

2020/07/22

2.3K0

Locust性能测试工具核心技术@task和@events

python 性能测试腾讯云测试服务 https

Tasks和Events是Locust性能测试工具的核心技术，有了它们，Locust才能称得上是一个性能工具。

dongfanger

2021/06/10

4590

生成代码，从 T 到 T1, T2, Tn —— 自动生成多个类型的泛型

发布于 2018-01-31 05:38 更新于 2018-05-25 12:33

walterlv

2018/09/18

1.4K0

生成代码，从 T 到 T1, T2, Tn —— 自动生成多个类型的泛型

从1.6T光模块到51.2T交换芯片，寡头的狂欢！

400G网络设备产业现状：完结篇 800G网络设备产业现状：技术篇 800G网络设备产业现状：芯片篇 800G网络设备产业现状：思科篇 800G网络设备产业现状：光模块篇当诺基亚这种老厂都说400G已经到了拐点那就代表400G已经是池中物因此在早前结束的OFC2021 800G技术成为国内外各大光模块厂商的主战场华安证券在会议结束后推出的通信行业周报对800G现状做了一个简单明了的梳理总结除了高端光模块相关产业链的进展报告将重心放在数据中心因为以太网光模块将占

用户6874558

2023/02/15

1.2K0

从1.6T光模块到51.2T交换芯片，寡头的狂欢！

Spark Task 的执行流程② - 创建、分发 Task

task 的创建本应该放在分配 tasks 给 executors一文中进行介绍，但由于创建的过程与分发及之后的反序列化执行关系紧密，我把这一部分内容挪到了本文。

codingforfun

2018/08/24

7250

Spark Task 的执行流程② - 创建、分发 Task

相似问题

await Task<T>和Task<T>.Result有什么不同？

23

IAsyncEnumerable<T>和IEnumerable<Task<T>>有什么不同？

232

ASP.NET核心应用编程接口- ActionResult<T>与异步Task<T>

20

将Task<DbSet<T>>转换为Task<IEnumerable<T>>

36

不等待从EF核心查询返回Task<IReadOnlyCollection<T>>？

12

添加站长进交流群

领取专属 10元无门槛券

AI混元助手 在线答疑

关注 腾讯云开发者公众号

洞察 腾讯核心技术

剖析业界实践案例