当前位置: 首页 > 知识库问答 >
问题:

群集范围的未定义行为[ThreadName=Data-Streamer-Stripe

蔡明贤
2023-03-14

我实际上是在加载CA。5'000'0000条记录。过了一段时间(500'000条记录),我收到了以下消息

严重:检测到阻塞的系统关键线程。这可能导致集群范围内的未定义行为[ThreadName=Data-Streamer-Stripe-2,BlockedFor=17s]rto_1 Mar.082020 5:02:08 PM java.util.logging.logManager$RootLogger日志rto_1 Severe:检测到严重的系统错误。将根据配置的处理程序[hnd=stopnodeorhaltfailurehandler[trystop=false,timeout=0,super=abstractfailurehandler[ignordfailuretypes=[SYSTEM_WORKER_BLOCKED,SYSTEM_CRITICAL_OPERATION_TIMEOUT]]],failurerectx=failurecontext[type=SYSTEM_WORKER_BLOCKED,err=class o.a.i.igniteexception:GridWorker[name=data-streamer-stripe-2,rker.java:297)rto_1在org.apache.ignite.spi.discovery.tcp.serverimpl$ringmessageworker.lambda$new$0(serverimpl.java:2663)rto_1在org.apache.ignite.spi.discovery.tcp.serverimpl$messageworker.body(serverimpl.java:7181)rto_1在org.apache.ignite.spi.discovery.tcp.serverimpl

我尝试在服务器节点上进行导入,然后切换到专用的客户端节点。与设置无关,流式线程似乎要花几秒钟的时间。我还尝试将DataStreamerThreadPoolSize设置为4,将StreamerNodeBufferSize设置为200,这样可以更快地完成写入。没有任何成功。

有什么建议如何解决这个问题?

共有1个答案

慕永年
2023-03-14

我认为这可能与“关键工作线程活性检查”有关

尝试为下列配置之一设置必要的值。

1) see if you can disable Disk Persistence (if enabled)

// submit data to nodes after this time
2) IgniteDataStreamer.autoFlushFrequency(100);

// Maximum number of parallel stream operations for a single node.
3) IgniteDataStreamer.perNodeParallelOperations(48);

// disable write-through behavior
4) IgniteDataStreamer.skipStore(true); 

// Allow overwrite, false to no-overwrite
5) IgniteDataStreamer.allowOverwrite(true);

如果您没有找到任何根本原因,那么至少用错误处理找到根本原因。

 类似资料:
  • 我有以下html: 我试图获得如下范围: 但我收到:。 我是angularJS初学者,我只是不明白为什么这不起作用。 更新:这也不起作用: 更新2:我试图在控制台中打印出作用域的所有代码:

  • 尽管标题出现了,但这并不是一个哲学问题。 从未初始化的数组读取 使用错误数据 使用不可移植构造。(即内存分配的细节1) 导致具有的行为 标准没有要求产生可预测的效果 我会称之为“未定义的行为”。但也许我错过了什么(?) null null

  • 问题 你想定义一个数组的范围。 解决方案 在 CoffeeScript 中,有两种方式定义数组元素的范围。 myArray = [1..10] # => [ 1, 2, 3, 4, 5, 6, 7, 8, 9, 10 ] myArray = [1...10] # => [ 1, 2, 3, 4, 5, 6, 7, 8, 9 ] 要想反转元素的范围,则可以写成下面这样。 myLargeArray =

  • 我有3个经纪人Kafka设置。我正在更新“min.insync.replicas”属性,我查看了文档, min.insync.replicas 更新模式:群集范围 集群范围在这里指定什么-它是否可以,如果我更新属性在一个代理或它需要更新在所有的代理设置文件(server.properties) 如何更新集群范围属性使用kafka-config- 所有可在集群级别配置的配置也可以在每个代理级别配置(

  • 作为一个Vue.js的初学者,我有一个看起来像这样的组件: “data.artist.name”在传递给数据道具的对象中存在且正确。但是我怎样才能摆脱关于嵌套艺术家名称的警告呢? [Vue warn]:计算表达式“data.artist.name”时出错:类型错误:scope.data.artist未定义(在组件中找到): 埃塔:啊,对不起,是的,显示“数据”会有帮助: {“id”:23182,“

  • 在尝试为Sublime Text 2编写自己的片段时,我遇到了以下两个问题: > 查找作用域键。我发现我可以逐个查看我的包并找到对声明的“scope”属性的引用。例如,在(我的HTML包中的一个文件)中,有以下两行: 因此,如果我希望我当前的片段在javascript文件上工作,我将我的范围定义为: 我假设所有这些范围键都是根据我安装的软件包即时定义的。Sublime Text是否在我可以更容易引