0

我有两个 fuseki。我正在尝试从一个 fuseki 获取一些数据并将其发送到另一个。我正在使用的查询是这样的:

SELECT ?g ?s ?p ?o WHERE { GRAPH ?g { ?s ?p ?o } GRAPH ?g { ?s <mo:metric> "metricA"^^<http://www.w3.org/2001/XMLSchema#string> } }

我得到了很多用于 metricA 的数据,然后我通过以下方式发送每个数据:

accessor.add(graph,model))

为了加快进程,我使用 Executors.newCachedThreadPool创建许多线程来发送它们。

问题来了,我注意到发送一些指标没有问题,即使我发送它们的间隔只有 100 毫秒。但是,对于一些其他指标,一段时间后,fuseki 服务器将无响应。即使我尝试访问 web gui,我也无法得到任何东西。但是,如果我当时停止发送数据,有趣的是 fuseki 开始接收大量消息。之前好像被屏蔽了。

有没有人可能是什么问题?

4

0 回答 0