回答情况：
提问时间：
问题标签：
我正在试着做一个有背压的可流动的。我的想法是，在当前项之一完成处理之前，不会发出可流动对象的新项。我使用ResourceSubscriber和subscribeWith()方法来实现这一点。 flowable的每个元素都在单独的线程池中进行异步处理。(这是通过使用flatMap/subscribeOn实现的) 我希望秒之后的每个元素都会在调用subscriber的onNext方法之后发出。但是，当我尝试运行这段代码时，可流动的代码无法控制地发出元素。背压不起作用。 下面是重现该问题的代码： import io.reactivex.Flowable;
import io.reactivex.s
浏览 21提问于2020-06-25得票数 3
回答已采纳
我正在使用带有DROP BackPressure策略的RxJava 2 Flowable。有没有办法收集有关由于BackPressure而实际丢弃了多少消息的信息/统计数据？
浏览 18修改于2017-01-16得票数 2
回答已采纳
我的计划是使用add_backpressure_callback函数来拥有一个函数，每当我们需要施加背压时，该函数将调用time.sleep(0.5)。
浏览 1提问于2012-08-08得票数 2
回答已采纳
这就是我对这个问题的理解。发布服务器和订阅服务器的伪代码类似于， Subscriber s; this.s = s; onRequest(int n){ s.onNext(messages);
浏览 1修改于2017-10-17得票数 2
Flink Web UI有一个出色的背压部分。但我看不到任何指标，由普罗米修斯记者给出，可以用来检测背压的相同方式为Grafana仪表盘。 ? 有没有办法在Flink Web UI之外获得相同的指标？使用此处描述的指标https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html。或者甚至有一个普罗米修斯刮刀来抓取web api？
浏览 68修改于2019-03-13得票数 2
回答已采纳
spark.batch.duration=10 secondsspark.streaming.backpressure.initialRate=60并使用以下参数指定了spark.streaming.backpressure.rateEstimator=pid
spark
浏览 2修改于2020-06-20得票数 3
("spark.streaming.backpressure.enabled",”true”)
启用或禁用火花流的内部背压机制(自1.5起)。既然我是第一次运行应用程序，并且没有以前的微批处理，那么我应该为：spark.streaming.backpressure.initialRate指定一些值吗？如果是这样，我应该如何确定spark.streaming.backpressure.initialRate的值。文档还指出，如果将spark.streaming.backpressu
浏览 0修改于2021-09-18得票数 4
回答已采纳
我在我的安卓应用中使用了RxJava。我正在使用一个使用interval()函数的计时器，但是即使我添加了onBackPressureDrop()，我也得到了一个丢失的背压异常。我还向我的订阅者添加了onError()，并将异常记录到Crashlytics中，但它仍然崩溃。请帮帮忙。我花了一周的时间来解决这个问题，但一无所获。代码偶尔崩溃，我甚至一次也没能重现它。TraceonError直接取自rxjava git上的一个官方问题。我认为它是负责打印Crashlytics异常的人，尽管我可能错了。serviceStartSubscription = Observable.
浏览 17修改于2016-09-23得票数 0
= append(s.backPressure, item)
new backpressure</em
浏览 2修改于2019-05-30得票数 3
回答已采纳
(5))(after backpressure map, and Rim 3 operation of source -2,74)
(after backpressure map, and Rim 3 operation of source
浏览 2修改于2019-04-26得票数 4
回答已采纳
1回答
在早期版本的Storm中，似乎可以通过将topology.backpressure.enable设置为false来禁用自动背压。在的源代码中，我看到了以下代码片段： * Whether to enable backpressure in for a certain topology.Will be removed soon.@Deprecatedpublic static final String TOPOLOGY_BACKPRESSURE_ENABLE= "topo
浏览 2提问于2020-01-16得票数 1
下面是我的设置：
spark.streaming.backpressure.pid.minRate
浏览 4修改于2017-11-17得票数 0
因此，下面的问题是，应用于spark流的属性是否也适用于spark结构化流，例如：
spark.streaming.backpressure.initialRate spark.streaming.backpressure.enabled
浏览 1修改于2021-03-08得票数 1
我一直在寻找新的rx java2，我不太确定我是否已经理解了backpressure的想法……
我知道我们有不支持backpressure的Observable和有backpressure支持的Flowable因此，我目前在脑海中找不到答案的基本问题是，为什么我要关心backpressure，当我可以使用普通的Observable时，仍然可以在不管理buffer的情况下接收所有值？或者从另一个角度来看，在管理和处理消费方面，backpressure给我带来了什么好处？
浏览 19提问于2016-10-30得票数 146
回答已采纳
(1)).onNext(4);}谢谢!
浏览 0提问于2017-03-14得票数 0
回答已采纳
2回答
buffer = 100
.delay(2.second, DelayOverflowStrategy.backpressure)
val kafkaSource: Source[Data, Consumer.Control
浏览 9提问于2017-10-16得票数 0
回答已采纳
backpressure-check-timer [DEBUG] Checking for change in Backpressure status on worker's tasks2022-09backpressure-check-timer [DEBUG] Checking f
浏览 34修改于2022-10-03得票数 1
回答已采纳
AbstractSolrSecondaryIndex.java (line 499) Truncated commit log for core grid_v2 INFO [Index WorkPool backpressureAbstractSolrSecondaryIndex.java (line 822) Increa
浏览 3修改于2015-04-10得票数 1
回答已采纳
Waiting on a flush to complete (backpressure being applied)
using (var delayCts = new CancellationTokenSource
浏览 5提问于2022-03-20得票数 2
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号