Marklogi c DataHub Сбой потока гармонизации - PullRequest
Новая
       74

Marklogi c DataHub Сбой потока гармонизации

0 голосов
/ 09 апреля 2020

У меня есть приложение java, которое использует marklogi c datahub API. Я управляю потоком на двух отдельных объектах. В процессе гармонизации один объект проходит нормально, а другой отказывает. Казалось, что это начало происходить неожиданно, так как раньше все работало нормально, и я не верю, что внесла какие-либо изменения, которые могли бы повлиять на это. У меня 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));

вот вывод для двух сущностей:

Задание выполнено с идентификатором задания: b9f105d0-df3 c -4f79- 8b3b-dc7b3a6dfcab идентификатор элемента xxxxxxx

Сбой задания с идентификатором задания: cda1ac16-32ba-4d29-a135-dbed6e918057 идентификатор элемента xxxxxxx

Почему это может происходить? Оба объекта были настроены одинаково с одинаковыми файлами содержимого.s js. На самом деле не существует трассировки стека, которую я могу использовать, чтобы докопаться до сути.

...