InvalidTopologyException(消息:组件：[x]订阅不存在的流[y]
InvalidTopologyException是一个错误类型，用于表示在Apache Storm分布式计算系统中出现的拓扑无效的异常情况。拓扑是Storm中的一个概念，表示一个分布式计算任务的逻辑结构，由多个组件和它们之间的数据流组成。
在这个错误消息中，"组件：[x]订阅不存在的流[y]"表示拓扑中的一个组件（Component）尝试订阅一个不存在的数据流（Stream）。这可能是由于配置错误、命名错误或者拓扑定义不一致等原因导致的。
解决这个问题的方法通常包括以下几个步骤：
- 检查拓扑定义：确保拓扑定义中所有组件和数据流的命名和配置正确无误。可以通过查看拓扑的代码或配置文件来进行检查。
- 检查组件和数据流的连接关系：确认组件之间的连接关系是否正确，即每个组件是否订阅了正确的数据流。可以通过查看拓扑的代码或配置文件来进行检查。
- 检查数据流的生成和发送：确认数据流是否正确生成和发送。可以通过查看数据流的生成代码或者发送代码来进行检查。
- 检查拓扑的部署环境：如果拓扑在分布式环境中运行，需要确保所有的节点都具备正确的配置和依赖项。可以检查拓扑的部署文档或者与系统管理员进行沟通。
腾讯云提供了一系列与分布式计算相关的产品和服务，例如腾讯云容器服务（Tencent Kubernetes Engine，TKE）、腾讯云函数计算（Tencent Cloud Function Compute，FC）、腾讯云弹性MapReduce（Tencent Elastic MapReduce，EMR）等，可以帮助用户构建和管理分布式计算任务。具体产品介绍和文档可以参考以下链接：
- 腾讯云容器服务（TKE）：https://cloud.tencent.com/product/tke
- 腾讯云函数计算（FC）：https://cloud.tencent.com/product/fc
- 腾讯云弹性MapReduce（EMR）：https://cloud.tencent.com/product/emr
请注意，以上答案仅供参考，具体的解决方法和推荐产品应根据实际情况进行评估和选择。
相关·内容
1回答
InvalidTopologyException(消息:组件：[x]订阅不存在的流[y]
apache-storm、apache-storm-topology
这是我的提交者文章。对于最后一行，我得到了下面的错误： InvalidTopologyException(msg:Component: [cassandrabolt] subscribes from non-existent这是CheckingBolt中的outputFieldDeclarer public void declareOutputFields(OutputFieldsDeclarer ofd) {
ofd.declareStream(cassandraBoltStream, new Fields(new String[
浏览 29提问于2020-01-21得票数 0
回答已采纳
1回答
Apache : InvalidTopologyException(msg: component：[x]订阅不存在的组件[y]
java、apache-storm
我使用了来自的代码(它工作得很好)：builder.setSpout("line-reader-spoutbuilder.createTopology());
但是，当我将其调整为有两个读行口，将这些行发送到两个word-spitter螺栓，最后将结果发送到单个word-counter螺栓时，就会抛出无效拓扑的例外我看不出有什么不正当的流动。当word-spitter2实际创建时，它怎么可能不存在？(拓扑名称=‘H
浏览 8提问于2016-04-13得票数 1
回答已采纳
1回答
跨GCP项目重新发布Google消息
google-cloud-platform、design-patterns、publish-subscribe、messaging、google-cloud-pubsub
上下文
如果云PubSub本机不支持这种设置，那么可能采用什么方法呢？P.S.我是P
浏览 2提问于2021-11-19得票数 0
2回答
CE更新事件:在属性值之前/之后传递给工作流的任何方式吗？
filenet-p8、filenet-content-engine、filenet-cpe
我已经在添加、更新和删除事件上配置了FileNet工作流订阅。工作流调用Java组件发送通知消息(向第三方)。
我们希望在“更新”事件的通知消息中看到“前”和“后”的属性值。触发订阅的“事件”对象有一个“修改的属性”成员，因此我希望能够在工作流中创建相应的"ModifiedProperties“字符串数组，并拥有订阅映射"Up
浏览 2提问于2018-07-29得票数 2
回答已采纳
1回答
如果数据在查看另一个组件时发生更改，则组件DOM不会更新
angular、rxjs、electron
我有一个有几个组件的应用程序，每个组件都异步显示不同的数据。我使用routerLink在不同组件之间导航。问题是，当组件A中的数据发生变化时，如果当前正在查看组件B，则当返回组件A时，DOM不会使用新数据进行更新( ngFor列表将继续显示test1、test2而不是接收到的数据)。但是，使用console.log，我可以在Dev工具中看到组件A在查看组件B时仍在接收数据。如果我在
浏览 0提问于2019-02-09得票数 0
回答已采纳
1回答
.NET XMPP/Jabber与Openfire服务器竞争以获取XML流消息
.net、xmpp、openfire
我希望.NET开源库订阅Openfire服务器来获取XML流消息(而不是聊天消息)。需要说明的是:像Pidgin这样的XMPP客户端通常有一个名为"XMPP Console“的插件，用于从远程XMPP服务器获取XML流。如何在Jabber-NET或S22.Xmpp组件中获取？
浏览 14提问于2019-03-24得票数 2
2回答
使用Azure服务总线传输的NServicebus中的事务
azure、transactions、nservicebus、nservicebus4
我在一个特定的端点中有几个消息处理程序，它们针对SQL Azure数据库执行它们的工作(目前仍在使用本地SQL 2012实例)。我有一个发布2个事件的命令处理程序，称为X和Y。在同一个端点中，我有一个订阅者X和一个订阅者Y。这两个订阅者在内部使用相同的数据访问组件，称为Z。依赖注入是在每个调用的基础上配置的，而不是共享的
浏览 9提问于2014-09-22得票数 0
1回答
如何将消息传递集成到自定义模块中？
rules、emails、notifications
我正在开发一个自定义模块来处理内部网站点的超时请求，我希望模块能够将电子邮件通知发送给一个可配置的用户列表--特别是请求用户的主管以及CC:人力资源代表。我看过，我假设其中一个或两个都公开了一个API，但我找不到任何关于如何将其集成到自定义模块中的文档。我也看过规则，虽然我不确定这是最好的解决方案。我总是可以做一个完全定制的工作，但是如果有一个更好的Drupal风格的解决方案，比如连接到这些现有的通知模块中的一个，我不愿意重新发明轮子
浏览 0提问于2016-05-26得票数 2
回答已采纳
1回答
Rxjava中的条件组播
java、rx-java、rx-java2
要发送的消息流是无限的(实现为可观察的)。调度组件需要向订阅方(S1、S2、S3、S4)发送多播消息。我是RxJava<e
浏览 2提问于2021-07-21得票数 0
1回答
用于SNS和SQS的boto python方法是否是同步的？
asynchronous、amazon-web-services、boto、amazon-sqs
测试用例的一部分涉及以下步骤：
检查X是否不存在。我的测试用例通常运行良好，直到步骤6的检
浏览 4提问于2015-04-06得票数 1
回答已采纳
1回答
cacheEntryRemoved的承诺什么时候实现？
caching、redux、react-redux、rtk-query、rtk
医生说：上面的引号是否意味着当使用查询的组件卸载时，承诺就实现了？
那么当组件接收流更新时呢？当从WS服务器接收到的消息的一部分不再需要时，在W
浏览 3提问于2021-08-08得票数 1
回答已采纳
1回答
将graphql查询与订阅相结合
javascript、graphql
我正在使用graphql订阅来获取一个活动消息流。我面临的问题是如何将其与查询结合起来，因为过去有消息。我的例子是，我有一个MessagesQuery组件来获取所有以前的消息，但是为了显示更新的消息，我使用了一个MessageSubscription组件。
有人能解释一下这方面的最佳方法吗？我找到了这个，但不幸的是没有反馈。给定的。
浏览 4提问于2019-08-09得票数 0
回答已采纳
2回答
订阅以角为单位的列表长度
angular、rxjs
假设有两个组件，分别命名为组件A和组件B。注意:组件A和组件B不一起出现在屏幕上。他们有不同的路线。例:本地主机:4200/组件，本地主机:4200/组件b
因此，当组件A存在时，组件B不存在，反之
浏览 5提问于2022-10-16得票数 0
1回答
角5 Rxjs Subject.subscribe()不触发多个组件
javascript、angular、rxjs
我使用rxjs和subjects来更新我的两个组件。我的</
浏览 0提问于2018-05-13得票数 2
回答已采纳
1回答
如何在gcloud中执行“实时请求批处理”
google-cloud-platform、routes
以下是我的情况：
I有一个运行在GPU上的相当慢的tensorflow模型(每个预测2到3秒)--对单个‘实体’的预测和对8‘实体的预测的预测几乎同时使用--这意味着，只要简单地将同一个请求中的多个预测组合起来，我就可以提高8倍的效率--我在人工智能平台上有一个服务，向该模型提供请求<<代码>H19<//代码>，但是服务的扩展速度很慢(任何超过4个QPS的事情都难以处
浏览 1提问于2021-05-31得票数 0
1回答
VCP Google Cloud Platform的数据流发布/订阅主题到BigQuery，而不是从订阅中提取数据
google-cloud-platform、google-bigquery、google-cloud-dataflow、google-cloud-pubsub、private-cloud
我正在使用GCP处理和存储从模拟IoT设备发送的数据。数据(应该)在以下路径中流动： 带有mqtt客户端的模拟IoT设备-> IoT核心设备-> IoT核心注册表->发布/订阅主题->发布/订阅订阅->云数据流发布/订阅订阅BigQuery模板-> BigQuery表 我所在的公司有一些GCP配置(它在VPC上)，这需要我指定一个subnet for DataFlow
浏览 21提问于2021-10-01得票数 0
回答已采纳
1回答
Angular获取ngFor中引用id的值
.net、angular、reference、ngfor
我目前正在与角度和SQL Server后端的.NET应用程序接口的个人项目。现在我不想使用外键，因为这样您就依赖于数据库了。所以我的模型确实有引用的id，它引用了其他对象。这个应用程序的主要目的是创建一个任务列表，表明任务是否完成，以及任务被分配给谁。例如，任务模型有一个名为："responsible_user_id"：1的属性。数字1表示id =1的用户负责此任务。task.item_status)"> <i style=&q
浏览 3提问于2021-10-08得票数 0
1回答
为什么我应该使用mergemap而不是嵌套的http调用？
angular、typescript、rxjs、observable
我在RXJS库的帮助下创建了嵌套的http调用： this.http.get(character.homeworld(homeworld => { this.loadedCharacter = character;但是我的一些teem mets告诉我使用streams和R
浏览 3提问于2020-10-24得票数 1
回答已采纳
1回答
应该创建一次或定期推送PubSub订阅吗？
publish-subscribe、google-cloud-pubsub
我的计划是使用推送订阅使数据在发布时立即处理。什么是推送订阅创建的好设计模式？我应该使用PubSub管理接口创建一次推送<
浏览 2提问于2016-10-25得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
