1回答
我们希望在某些自定义时间间隔内再次重试相同的事件。失败也可能是因为一些调用后验证，因此从代码触发。我们发现：不确定这是否已经实现。如果没有，有没有出路？或者只是在过滤后将需要重试的事件推送回输入流？
浏览 16提问于2020-02-05得票数 0
回答已采纳
1回答
问题是，我只看到了一个对这个文件的调用，而不是3(正如我在RetryPolicy中所指定的)，我还注意到调用在1秒内完成，所以它肯定不会等到10秒后再试一次.我怎么知道BlobClient是否真的做了重试
浏览 1提问于2016-07-15得票数 1
回答已采纳
1回答
我在.NET Core2.2中的一个应用程序接口上实现了自定义重试策略。重试策略应仅适用于数据库(Azure SQL)中的暂时性错误。如何生成瞬态错误来测试此功能？
浏览 24提问于2020-05-23得票数 1
我的Flink处理器监听Kafka，处理器中的业务逻辑涉及调用外部REST服务，并且这些服务可能会宕机。我想把元组重新放回处理器中，有没有办法这样做？在Flink中，一旦消息被Flink-Kafka Consumer消费，元组就会被自动确认。有一些方法可以解决这个问题。一种这样的方法是将消息发布回相同的队列/重试队列。我知道Flink的保存点/检查点将用于容错。但在我的理解中，在Flink失败的情况下，元组将被重播。我想了解一下如何处理暂时性故障。 谢谢
浏览 32提问于2020-03-31得票数 1
1回答
，有一个内置重试策略，如果服务总线返回瞬态异常，它将重试5次。如果出现这两种情况之一，我想编写一条日志语句：
发生瞬态错误，但重试策略的所有重试都失败。在出现瞬态异常的情况下，我的log语句会对重试策略所做的每一次重试执行吗？还是重试策略尝试五次，然后重新抛出异常，以便我的自定义日志语句只在重试后执行一
浏览 4提问于2020-10-12得票数 1
回答已采纳
在MassTransit中，如何通知用户在重试策略停止重试后发生了错误？当消息被发送到错误队列时，我是否可以运行自定义代码，也许作为某种中间件？
浏览 1提问于2015-09-08得票数 1
回答已采纳
然而，有一些异常通常意味着代码中的错误(例如NullPointerException或任何其他未处理的异常)，在这种情况下，我不想应用任何重启策略，因为任何次数的重启都不能解决问题。在这种情况下，有没有办法在配置了策略的情况下从作业内部停止作业？
浏览 1提问于2019-04-02得票数 1
1回答
如果我对此有正确的理解，火花流是用于在转换之后用输出操作将RDD批处理通过一组转换。这是对每个批处理执行的，因此输出操作也对每个批执行。但是由于每次做输出的成本太高，我想要处理批次并积累结果，并且只在某些情况下(例如在某个时间段之后)写出累积的结果并结束程序。这有可能吗？
浏览 0提问于2015-07-07得票数 2
DefaultRetryPolicy的文档显示
在读取超时时，如果答复了足够多的副本，但没有检索数据。这种重试策略是保守的，因为它不会以与初始操作不同的一致性级别重试。这是否意味着，当我在不使用任何自定义重试策略的情况下执行一个简单的session.execute(BoundStatement)，并获得一个写入超时，默认的重试策略就会启动，并且会再次重试写入数据吗？
浏览 0提问于2018-09-25得票数 0
回答已采纳
我是否可以在Flink中编写自定义触发器策略，它通过查看一组键而不是单个键来决定是否发出？
浏览 1提问于2018-03-06得票数 1
1回答
我有一个自定义的重试策略，只要应用程序接收到非404的http状态码，它就会执行重试。我还创建了一个重试模板。我被困在如何使用重试模板执行自定义重试策略上。我已经包含了重试模板和自定义重试策略的代码。
浏览 12提问于2019-10-11得票数 0
根据亚马逊网络服务的StepFunction文档，可以配置每个错误的重试，但我想知道是否可以使用错误消息中的详细信息来定义重试策略？在我的例子中，我触发了Glue ETL job，它可能会失败，并返回自定义异常NoDataLoadedException，所以我希望能够识别它，并且不会重试。",} 是否可以使用error.ErrorMessage来确定任务的<
浏览 33提问于2019-02-09得票数 1
我正在通过实现datastax 来自定义重试策略。我注意到，当触发时，重试策略在datastax框架创建的新线程中执行。因此，我正在丢失上下文，并且无法在原始查询执行和当前重试执行之间进行链接(我的相关上下文数据存储在上)。是否有一种方法可以将数据注册/传递到重试策略中，以便能够利用原始查询中的信息？
浏览 11提问于2019-03-28得票数 0
我在集群模式下启动flink并提交flink作业。我已经在flink配置中配置了24个任务槽，对于该任务，我使用了6个任务插槽。在代码中，我启用了检查点，并将重新启动策略设置为fixedDelayRestart。
这是一个Flink流作业。它
浏览 4提问于2018-01-15得票数 2
我有一个作业正在运行，我感兴趣的是只使用一次恢复重试，因为在flink重新启动没有触发的同时，我有一个线程试图解决问题，然后当问题解决后flink会重新启动，但是有时候线程需要比通常更长的时间来修复问题，重新启动策略被触发，因为问题仍然是失败的，然后作业被停止，但是线程可能有另一个迭代，然后应用程序永远不会死，因为我将它作为一个jar应用程序运行。
浏览 7提问于2020-06-18得票数 2
1回答
如果与数据库的连接丢失了，那么我需要能够设置重试次数，以及微服务配置文件中重试之间的毫秒数。我使用的是“spring版本1.5.6”和spring cassandra版本1.5.6“。通过创建CassandraCqlClusterFactoryBean类型的集群并在cluster.setReconnectionPolicy()方法中传递自定义重连接策略，我能够设置重试之间的毫秒数。但是，我无法使用自定义重试策略设置重试次数。如果正确理
浏览 1提问于2017-10-26得票数 2
在我的C#程序中，我使用实体框架将本地Server数据库与QuickBooks数据同步。从QuickBooks获取数据似乎没有任何问题。但是，在对实体进行批量提交时，我遇到了一个绊脚石。但是，我看不到在数据上下文中这样做的方法，因为在使用SaveChanges()时，这似乎是一个全部或根本不重要的问题。是否有一种方法来处理我想要完成的事情，或者我是否应该以一种完全不同的方式来处理这些失败？
下面
浏览 3提问于2017-05-30得票数 1
回答已采纳
我正在阅读Flink的检查点机制的细节，现在，我认为我已经有了一个很好的概览，所有的东西是如何联系在一起，但最后一个问题，我在这里。我主要是在思考commit消息或其回调的潜在故障时，在Flink博客中偶然发现了这一段：
在成功的预提交之后，提交必须保证最终成功--我们的操作员和外部系统都需要这样的保证。如果提交失败(例如，由于间歇性网络问题)，整个Flink应用程序将失败，根据用户的重新启动策略重新启动，然后再次尝试提交。此过程至关重要，因为如果提交最终不成功，则会发生数据丢失。是否意味着，如果定义的重试</e
浏览 1提问于2020-10-02得票数 1
回答已采纳
我正在尝试AWS SNS交付重试策略，让它每1小时重试10小时。
无法设置主题传递重试策略。错误代码: InvalidParameter -错误消息:设置属性传递重试策略(http/s)时发生错误。无效参数: DeliveryPolicy: http.defaultHealthyRetryPolicy:总策略重试<
浏览 5提问于2022-04-22得票数 1
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
