1

我们使用的是 mlcp 9.0.6 版。平台：Linux

当我们通过企业调度程序 Zena 运行 mlcp 作业时，尽管 mlcp 成功完成，但任务在 Zena 上失败。

我们尝试通过相同的任务运行 gradle harmonize job，它运行成功。我们还尝试了一个简单的文件移动功能，也很成功。但是 mlcp 没有将预期的成功响应返回给我们的企业调度程序，导致我们的企业调度程序任务失败。

以下是 mlcp 返回的示例日志。如日志所示，mlcp 加载成功，我能够验证 STAGING DB 中的数据，但是，mlcp 没有将成功响应传回调度程序。

错误：19/05/09 15:47:48 INFO contentpump.LocalJobRunner：内容类型：XML 19/05/09 15:47:48 INFO contentpump.ContentPump：作业名称：local_1527018875_1 19/05/09 15:47:48 INFO contentpump.FileAndDirectoryInputFormat：要处理的总输入路径：1 19/05/09 15:47:50 INFO contentpump.LocalJobRunner：完成 47% 19/05/09 15:47:51 INFO contentpump.LocalJobRunner：完成 100% 19/ 05/09 15:48:23 信息 contentpump.LocalJobRunner：com.marklogic.mapreduce.MarkLogicCounter：19/05/09 15:48:23 信息 contentpump.LocalJobRunner：INPUT_RECORDS：2798 19/05/09 15:48:23 信息contentpump.LocalJobRunner: OUTPUT_RECORDS: 2798 19/05/09 15:48:23 INFO contentpump.LocalJobRunner: OUTPUT_RECORDS_COMMITTED: 2798 19/05/09 15:48:23 INFO contentpump.LocalJobRunner: OUTPUT_RECORDS_FAILED: 0 19/05/09 15: 48:23 INFO contentpump.LocalJobRunner：总执行时间：35 秒

更新

这是mlcp代码

#!/bin/bash

mlcp.sh import -ssl \
-host testhost \
-port 8010 \
-username unm \
-password pw \
-mode local \
-input_file_path /data/SourceFiles/QA/Customer \
-input_file_type aggregates \
-aggregate_record_namespace "http://new.webservice.namespace" \
-output_collections customerstaging,customerHarmonize \
-output_permissions data-hub-role,read,data-hub-role,update \
-output_uri_prefix /customer/ \
-aggregate_record_element PartyDownload \
-thread_count 48 \
-transform_module /ext/reusefunctions/customerDocument.sjs

exit 0

它最后有一个明确的“退出 0”，但工作仍然失败。我们能够成功运行如下协调步骤。

(cd /data/EODH && gradle hubRunFlow -PentityName="customer" PflowName="customer-harmonize-process" -PflowType="harmonize" -PenvironmentName=uat -PthreadCount=32)

if [ $? -eq 0 ]
then
  echo "Success: Files moved."
  exit 0
else
  echo "Failure."
  exit 1
fi
4

0 回答 0