调用并行函数模块时触发COMMUNICATION_FAILURE错误求助

核心错误点 #

1. RECEIVE函数名不匹配：你在read_finished方法里调用RECEIVE RESULTS FROM FUNCTION 'BAPI_PO_GETDETAIL'，但实际启动的并行任务调用的是BAPI_PO_GETDETAIL1。ABAP会因为找不到对应任务的返回结果，直接触发COMMUNICATION_FAILURE短转储——这是导致问题最直接的原因。

2. 等待逻辑不合理：WAIT UNTIL started_tasks LT processes - 1的条件限制了并行任务数最多为processes-2，完全浪费了进程组的资源。更关键的是，这种条件会打乱任务启动的时机节奏，和进程组的资源分配逻辑冲突，进一步加剧通信异常。

3. 进程数获取方式有误：SPBT_INITIALIZE返回的free_pbt_wps是当前空闲的并行进程数，而非进程组的总可用进程数。如果后续有其他任务占用进程，这个值会动态变化，导致你的等待逻辑判断失准。

修复步骤 #

1. 修正RECEIVE的函数名 #

把read_finished里的函数名改成和调用一致的BAPI_PO_GETDETAIL1，同时建议加上RETURN表用于错误排查：

METHOD read_finished.
  DATA addr TYPE STANDARD TABLE OF bapimepoaddrdelivery.
  DATA header TYPE bapimepoheader.
  DATA lt_return TYPE STANDARD TABLE OF bapiret2.

  RECEIVE RESULTS FROM FUNCTION 'BAPI_PO_GETDETAIL1'
    IMPORTING
      poheader = header
    TABLES
      poaddrdelivery = addr
      return         = lt_return.

  "后续逻辑...
ENDMETHOD.

2. 调整等待逻辑与进程数获取 #

• 改用SPBT_GET_NUMBER_OF_PROCESSES获取进程组的总可用进程数，而非当前空闲数，避免动态变化的干扰：

DATA(total_processes) TYPE i.
CALL FUNCTION 'SPBT_GET_NUMBER_OF_PROCESSES'
  EXPORTING
    group_name = 'parallel_generators'
  IMPORTING
    number_of_processes = total_processes.

• 修改等待条件为允许充分利用所有进程：

WAIT UNTIL started_tasks < total_processes.

3. 优化任务ID与异常处理 #

• 任务ID建议用独立的递增计数器，避免依赖sy-tabix（如果内表有循环或修改操作，sy-tabix可能出现重复）：

DATA(task_counter) TYPE i VALUE 0.
"循环内逻辑
task_counter = task_counter + 1.
DATA(taskid) = |PO_TASK_{ task_counter }|.

• 在read_finished中添加异常捕获，确保即使任务失败，started_tasks也能正确递减，避免主会话无限等待：

METHOD read_finished.
  DATA addr TYPE STANDARD TABLE OF bapimepoaddrdelivery.
  DATA header TYPE bapimepoheader.
  DATA lt_return TYPE STANDARD TABLE OF bapiret2.

  TRY.
      RECEIVE RESULTS FROM FUNCTION 'BAPI_PO_GETDETAIL1'
        IMPORTING
          poheader = header
        TABLES
          poaddrdelivery = addr
          return         = lt_return.

      "检查BAPI返回的错误信息
      READ TABLE lt_return TRANSPORTING NO FIELDS WITH KEY type = 'E'.
      IF sy-subrc = 0.
        "添加错误日志记录逻辑
        RETURN.
      ENDIF.

      set_address_and_distance(
        EXPORTING
          i_addr   = addr
        CHANGING
          c_header = header ).
    CATCH cx_ai_system_fault INTO DATA(lo_fault).
      "捕获通信/系统异常，记录日志
    CLEANUP.
      started_tasks = started_tasks - 1.
  ENDTRY.
ENDMETHOD.

4. 其他注意事项 #

• 确保started_tasks是全局/实例变量，ABAP中ON END OF TASK的回调是在主会话串行执行的，无需额外加锁，但要保证变量的可见性。
• 提前确认进程组parallel_generators已配置足够的并行进程，否则即使代码正确，也会因为资源不足触发异常。

内容的提问来源于stack exchange，提问作者Kevin Holtkamp