Job failure when deploying customized flows that contain API enrichment nodes

Symptoms

When a Flink deployment is created to deploy a job, the job manager pod fails with the following error in the log:

ERROR com.ibm.ei.streamproc.model.jobgraph.apinode.connector.ResponseJsonRowDataDeserializationSchema [] - Failed to convert response literal value xxx

Causes

The error might occur because your flow contains an API node, and you mapped an input parameter with a constant value.

Resolving the problem

To resolve the problem, you can follow one of the following options:

  • Use a transform node prior to the API node to create new event properties with constant values. Then, in the API node, map these new properties to the input parameters.
  • Export the flow as SQL and deploy by using the Apache SQL runner sample.