使用spark订阅事件中心时出现异常
使用Spark订阅事件中心时出现异常可能是由于以下原因：
- 配置错误：请确保您的Spark配置正确，包括事件中心的连接字符串、订阅名称、身份验证凭据等。您可以参考腾讯云的事件中心文档（https://cloud.tencent.com/document/product/849/48288）了解如何正确配置Spark与事件中心的集成。
- 事件中心访问权限：请确保您的Spark应用程序具有足够的权限访问事件中心。您可以在腾讯云的访问管理控制台（https://console.cloud.tencent.com/cam/policy）中为Spark应用程序创建适当的访问策略。
- 事件中心服务异常：如果事件中心服务出现故障或不可用，可能会导致订阅时出现异常。您可以在腾讯云的事件中心控制台（https://console.cloud.tencent.com/ces/eventhub）中检查事件中心的状态和健康状况。
- 代码错误：请检查您的Spark应用程序代码，确保订阅事件中心的逻辑正确。您可以参考腾讯云的Spark开发指南（https://cloud.tencent.com/document/product/849/48289）了解如何正确使用Spark与事件中心进行集成。
如果以上解决方法无法解决您的问题，请联系腾讯云的技术支持团队（https://cloud.tencent.com/document/product/849/48290），他们将为您提供进一步的帮助和支持。
相关·内容
1回答
(EventHubsClient.scala:149) at org.apache.spark.sql.execution.streaming.StreamExecuti
浏览 16提问于2019-01-09得票数 1
我创建了一个事件中心，并让工作代码从中心生成和使用事件，但是，当选择了“使用当前订阅中的事件中心”选项时，我去添加流分析作业，但添加输入对话框看不到我的命名空间。他们都在相同的订阅(我唯一的一个)，我是管理员，我的用户帐户是事件中心的所有者。为什么门户刀片不能“看到”我的事件中心命名空间和中心？它们也在相同的资
浏览 3提问于2017-05-06得票数 0
在创建事件网格订阅并使用eventhub作为端点时，没有办法指定应该向其发送所有消息的partitionID。有可能通过Web钩子吗？我在这里发现通过Rest是可能的。它使用下面的url。。我正试着把这些事件吃到事件中心。但是我想要的是这些事件被吸收到事件中心中的特定分区中。是否可以通过事件订阅(可能通过将deviceid作为参数传递)？或者是否有其他方法配置<e
浏览 2提问于2018-05-31得票数 0
回答已采纳
我有一个用例可以将事件中心作为订阅服务器添加到事件网格域主题中。在这里，事件网格域&事件中心驻留在两个不同的Azure订阅中(由同一个租户保护)
如何创建事件网格域主题订阅以通过az cli命令连接到事件中心？这是否可以仅用同时访问这些资源的SPN来完成，还是应该使用托管标识？
浏览 3提问于2022-10-13得票数 0
1回答
我要将发送到Azure Service Bus主题的事件发送到事件中心。这个是可能的吗？详细信息:我正在与我的公司中的一个不同的团队合作，该团队接收Azure Service Bus主题的第三方事件(通过webhook)，这将在不同的应用程序中进一步使用。我的团队现在希望使用我们现有的事件中心收听/订阅此主题，并使用azure capture将这些事件存储到存储帐户中。我做了以下工作： 我
浏览 24提问于2021-08-20得票数 0
回答已采纳
2回答
我正在探索如何使用蔚蓝事件中心作为事件使用者。
因此，我的.NET应用程序将事件发送到azure事件中心。默认情况下，事件中心有4个分区。我希望将事件存储在azure存储中，并将其传递给另一个.NET应用程序。这个问题是要问-- azure事件中心是否有能力将事件推送到blob和我的.NET应用程序，还是订阅服务器(blob和.
浏览 15提问于2022-11-04得票数 1
我使用的是，我订阅了单击视图中的事件，并对它们执行如下操作： .map(...)问题是，无论何时出现异常，subscriberA都会自动取消订阅，从而导致下一次单击不会触发任何操作。如何处理异常，以便拦截所有单击事件，而不考虑抛出的异常？
浏览 2提问于2014-10-02得票数 2
回答已采纳
我试图将事件网格连接到事件集线器，这样集线器将事件发送到网格，但我不知道如何在门户中这样做。这个是可能的吗？
我原以为是我创建了订阅，但它似乎正在向另一个方向发展(听网格的枢纽)。当我触发一个函数时，我可以看到集线器消息在不断增长，但是似乎没有什么东西能使它进入网格或我应该监听网格的函数中。Azure门户中的许多东西似乎都有一种创建网格订阅的方法，包括网格本身，但是很难判断当您创建网格订阅的方向是什么.我还没有找到任何描述这样做的文档，只使用捕获，这是
浏览 8提问于2018-02-13得票数 2
回答已采纳
2回答
我已经创建了EventGridTrigger类型的Azure函数，作为事件网格中主题的订阅者。该函数使用rest客户端调用下游api。但是，在某些情况下，下游api是不可维护的，或者在从EventGridLtrigger调用下游api时会出现异常。在这种情况下，我观察到EventGridTopic仍然显示已交付的事件，而不是在失败时重新尝试。
是否可以让EventGrid重试传递，或者在处理失败时将事件添加到死信队列中？
浏览 7提问于2022-06-29得票数 0
我期待连接Azure数据砖到事件中心，并通过splunk阅读它。最初，我能够发送一条测试消息，并能够在splunk中接收事件(可以按照 -->将tweet发送到事件中心)使用scala。现在，我尝试使用来自 -> Send的引用来使用python实现同样的功能。当我试图传递对象参数时，它会引发一个错误，比如无法从Azure事件中心导入。PS :我在集群中添加了所需的库如下：
com.
浏览 8提问于2022-08-09得票数 1
我想在一个程序中使用多个具有不同订阅的Azure-EventHub。我可以用不同的订阅创建多个eph新连接吗？我是否能够并行使用属于不同订阅的多个事件中心的事件？
浏览 12提问于2019-05-07得票数 1
回答已采纳
我使用将事件从事件中心流到DocumentDB。我按照文档配置了输入、查询和输出，并使用示例数据对其进行了测试，并设法按预期返回结果。但是，当我启动流作业并发送与前面的示例数据相同的有效负载时，我得到了以下错误消息：
按照DocumentDB约束对DocumentDB db:my-database-name和DocumentDB:my-collection-name"Tenant": "T1", "Status": "
浏览 4提问于2016-11-09得票数 0
回答已采纳
1回答
我试图使用以下代码从事件中心读取： .readStream \ .option("kafka.bootstrap.serversmaxOffsetsPerTrigger", 1000)\当我执行显示
浏览 2提问于2022-08-25得票数 0
回答已采纳
我正在尝试使用消息中心将数据从一个ViewModel发送到另一个。我已经在第二个ViewModel的构造函数中订阅了该事件。但该事件不会被订阅，因为直到我打开与ViewModel对应的页面/视图时，构造函数才会被编译。我使用的是MVVM Light，直到现在我才知道VM的构造函数是在应用程序启动时调用ViewModelLocator时编译的。
有人能帮助我更好地理解这一点吗?我如何订阅事件
浏览 0提问于2017-12-06得票数 0
3回答
我想阅读来自Azure IoT集线器的“”事件()。我发现的唯一示例涉及Azure事件网格，但我更愿意使用IoT集线器的内部端点(事件中心)。这有可能吗？当我使用EventProcessorHost接口订阅内部事件集线器时，我得到的只是D2C用户遥测消息。
浏览 0提问于2018-11-25得票数 3
我可能会对一些概念感到困惑，但我已经将Azure活动日志导出到Azure事件集线器(Azure Event Hub )。事件集线器insights-operational-logs是创建的，我看到事件张贴在那里。我也创建了事件订阅，但它根本不显示任何事件。我遗漏了什么？准确的步骤。转到Azure活动日志并将其导出到我选择的事件中心。
转到eventhub命名空间并单击"Events“，然后选择"+事件订
浏览 1提问于2019-02-22得票数 0
回答已采纳
我使用dataproc在java.But中运行spark作业，作业失败，错误如下。19/06/18 06:32:30接收器报告流0的WARN org.apache.spark.streaming.scheduler.ReceiverTracker:错误:无法在scala.collection.IterableLikeTraversableOnce.scala:294)在scala.collection.AbstractTraversable.toList(Traversable.scala:104)在org.apache
浏览 11提问于2019-06-24得票数 3
获取以下异常:线程"main“中出现异常: java.lang.UnsupportedClassVersionError: spark/Route :不支持的major.minor版本52.0
尝试使用spark web应用程序框架时，当我执行文件时，它抛出此异常。Spark Framework版本: 2.0.0
浏览 0提问于2014-06-03得票数 10
回答已采纳
1回答
我有一个通知中心，它是一个单子，每隔几秒钟在后台运行一次，从DB获取新的通知，如果有订阅他的事件，他会用新的通知触发事件。另一方面，我有一个订阅此事件的signalR客户端，如下所示： { }publ
浏览 1提问于2014-01-23得票数 3
回答已采纳
在我的生产案例中，Eventhub与ADX集群处于不同的订阅状态。通过数据接收角色，服务主体被赋予对对等服务器的访问权限。我已经将App(服务主体)添加到ADX数据库中。似乎我需要运行一个查询或编写一些代码来让ADX数据库使用服务主体从事件中心获取数据，但我的在线搜索并没有取得丰硕的成果。我应该遵循什么步骤？
在上面提到的文章中，我需要本节()的ADX等价物。
浏览 0提问于2019-07-24得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
