@Override
    public RequestBody getRequestBody() {
        try {
            return RequestBody.create(MediaType.parse("application/json; charset=utf-8"),
                    objectMapper.writeValueAsString(requestBodyParams));
        } catch (Exception e) {
            log.error("Airflow request body construction failed: {}", e.getMessage(), e);
            throw new AirflowScheduleException(BUILD_REQUEST_BODY_FAILED,
                    String.format("Airflow request body construction failed: %s", e.getMessage()));
        }
    }
Create JSON request body
@return RequestBody Object
inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/api/BaseAirflowApi.java