英文:
Marklogic DataHub Harmonization flow failure
问题
以下是您要翻译的内容：
我有一个使用 MarkLogic DataHub API 的 Java 应用程序。我在两个不同的实体上运行一个流程。在协调过程中，一个实体能够顺利通过，而另一个实体却失败了。这似乎是突然发生的，因为之前它还正常工作，我不认为我做了任何可能影响到这一点的更改。我在本地部署了 DataHub 5.0.2。以下是流程的代码。
FlowRunner flowRunner = flowManager.newFlowRunner().withFlow(harmonizeFlow)
.withBatchSize(4)
.withThreadCount(10).withOptions(null)
.withDestinationDatabase("final")
.onItemComplete((String jobId, String itemId) -> log.info("Job passed with job id :{} item id :{}",
jobId, itemId))
.onItemFailed((String jobId, String itemId) -> log.info("Job failed with job id :{} item id :{}",
jobId, itemId));
以下是两个实体的输出：
作业通过，作业 ID 为：b9f105d0-df3c-4f79-8b3b-dc7b3a6dfcab，项 ID 为 xxxxxxx
作业失败，作业 ID 为：cda1ac16-32ba-4d29-a135-dbed6e918057，项 ID 为 xxxxxxx
为什么会出现这种情况？这两个实体的配置相同，内容的 sjs 文件也类似。我无法获取堆栈跟踪以找出问题的根本原因。
英文:
I have a java application thats using the marklogic datahub API. I am running a flow on two separate entities. During the harmonization process, one entity passes fine while the other fails. This just seemed to start happening out of the blue as it was working fine earlier and I do not believe I made any changes that would effect this. I have datahub 5.0.2 deployed locally. Here is the code for the flow.
FlowRunner flowRunner = flowManager.newFlowRunner().withFlow(harmonizeFlow)
.withBatchSize(4)
.withThreadCount(10).withOptions(null)
.withDestinationDatabase("final")
.onItemComplete((String jobId, String itemId) -> log.info("Job passed with job id :{} item id :{}",
jobId, itemId))
.onItemFailed((String jobId, String itemId) -> log.info("Job failed with job id :{} item id :{}",
jobId, itemId));
here is the output for the two entities:
>Job passed with job id :b9f105d0-df3c-4f79-8b3b-dc7b3a6dfcab item id xxxxxxx
>Job failed with job id :cda1ac16-32ba-4d29-a135-dbed6e918057 item id xxxxxxx
Why might this be happening? Both entites were configured the same with similar content.sjs files. There is not really a stack trace I can use to get to the bottom of this.
专注分享java语言的经验与见解，让所有开发者获益！
评论