[🍒][PLUGIN-1838] Error Management catch known errors [GCSArgumentSetter]

[psainics]

🍒 [cherrypick]

Commits :

• c153c7c

PR:

• [PLUGIN-1838] Error Management catch known errors [GCSArgumentSetter] #1497 [ Reviewer @itsankit-google ]

---

Error Management catch known errors [GCSArgumentSetter]

Jira : PLUGIN-1838

Description

Error Management catch known errors

Code change

• Modified GCSArgumentSetter.java

Tests

• Test Case (Incorrect json format file provided)

Raw Logs

2025-01-20 09:13:48,323 - ERROR [WorkflowDriver:i.c.c.i.a.r.w.WorkflowProgramController@90] - Workflow service 'workflow.default.TEST_GCS_ARG.DataPipelineWorkflow.b9609e48-d6e0-11ef-a108-0000005fe079' failed.
io.cdap.cdap.api.exception.WrappedStageException: Stage 'GCS Argument Setter' encountered : io.cdap.cdap.api.exception.ProgramFailureException: Could not parse response from 'io.cdap.plugin.gcp.gcs.GCSPath@7b0634ba': com.google.gson.stream.MalformedJsonException: Unterminated array at line 8 column 6 path $.arguments[1]
  at io.cdap.cdap.etl.common.plugin.ExceptionWrappingCaller.call(ExceptionWrappingCaller.java:64)
  at io.cdap.cdap.etl.common.plugin.WrappedAction.run(WrappedAction.java:48)
  at io.cdap.cdap.etl.batch.customaction.PipelineAction.run(PipelineAction.java:91)
  at io.cdap.cdap.internal.app.runtime.AbstractContext.execute(AbstractContext.java:608)
  at io.cdap.cdap.internal.app.runtime.workflow.CustomActionExecutor.execute(CustomActionExecutor.java:90)
  at io.cdap.cdap.internal.app.runtime.workflow.WorkflowDriver.executeCustomAction(WorkflowDriver.java:449)
  at io.cdap.cdap.internal.app.runtime.workflow.WorkflowDriver.executeNode(WorkflowDriver.java:489)
  at io.cdap.cdap.internal.app.runtime.workflow.WorkflowDriver.executeAll(WorkflowDriver.java:669)
  at io.cdap.cdap.internal.app.runtime.workflow.WorkflowDriver.run(WorkflowDriver.java:653)
  at com.google.common.util.concurrent.AbstractExecutionThreadService$1$1.run(AbstractExecutionThreadService.java:52)
  at java.lang.Thread.run(Thread.java:750)
Caused by: io.cdap.cdap.api.exception.ProgramFailureException: Could not parse response from 'io.cdap.plugin.gcp.gcs.GCSPath@7b0634ba': com.google.gson.stream.MalformedJsonException: Unterminated array at line 8 column 6 path $.arguments[1]
  at io.cdap.cdap.api.exception.ProgramFailureException$Builder.build(ProgramFailureException.java:229)
  at io.cdap.cdap.api.exception.ErrorUtils.getProgramFailureException(ErrorUtils.java:161)
  at io.cdap.plugin.gcp.gcs.actions.GCSArgumentSetter.run(GCSArgumentSetter.java:107)
  at io.cdap.cdap.etl.common.plugin.WrappedAction.lambda$run$1(WrappedAction.java:49)
  at io.cdap.cdap.etl.common.plugin.Caller$1.call(Caller.java:30)
  at io.cdap.cdap.etl.common.plugin.ExceptionWrappingCaller.call(ExceptionWrappingCaller.java:62)
  ... 10 common frames omitted
2025-01-20 09:13:48,324 - DEBUG [WorkflowDriver:i.c.c.c.l.c.UncaughtExceptionHandler@40] - Uncaught exception in thread Thread[WorkflowDriver,5,main]
io.cdap.cdap.api.exception.WrappedStageException: Stage 'GCS Argument Setter' encountered : io.cdap.cdap.api.exception.ProgramFailureException: Could not parse response from 'io.cdap.plugin.gcp.gcs.GCSPath@7b0634ba': com.google.gson.stream.MalformedJsonException: Unterminated array at line 8 column 6 path $.arguments[1]
  at io.cdap.cdap.etl.common.plugin.ExceptionWrappingCaller.call(ExceptionWrappingCaller.java:64)
  at io.cdap.cdap.etl.common.plugin.WrappedAction.run(WrappedAction.java:48)
  at io.cdap.cdap.etl.batch.customaction.PipelineAction.run(PipelineAction.java:91)
  at io.cdap.cdap.internal.app.runtime.AbstractContext.execute(AbstractContext.java:608)
  at io.cdap.cdap.internal.app.runtime.workflow.CustomActionExecutor.execute(CustomActionExecutor.java:90)
  at io.cdap.cdap.internal.app.runtime.workflow.WorkflowDriver.executeCustomAction(WorkflowDriver.java:449)
  at io.cdap.cdap.internal.app.runtime.workflow.WorkflowDriver.executeNode(WorkflowDriver.java:489)
  at io.cdap.cdap.internal.app.runtime.workflow.WorkflowDriver.executeAll(WorkflowDriver.java:669)
  at io.cdap.cdap.internal.app.runtime.workflow.WorkflowDriver.run(WorkflowDriver.java:653)
  at com.google.common.util.concurrent.AbstractExecutionThreadService$1$1.run(AbstractExecutionThreadService.java:52)
  at java.lang.Thread.run(Thread.java:750)
Caused by: io.cdap.cdap.api.exception.ProgramFailureException: Could not parse response from 'io.cdap.plugin.gcp.gcs.GCSPath@7b0634ba': com.google.gson.stream.MalformedJsonException: Unterminated array at line 8 column 6 path $.arguments[1]
  at io.cdap.cdap.api.exception.ProgramFailureException$Builder.build(ProgramFailureException.java:229)
  at io.cdap.cdap.api.exception.ErrorUtils.getProgramFailureException(ErrorUtils.java:161)
  at io.cdap.plugin.gcp.gcs.actions.GCSArgumentSetter.run(GCSArgumentSetter.java:107)
  at io.cdap.cdap.etl.common.plugin.WrappedAction.lambda$run$1(WrappedAction.java:49)
  at io.cdap.cdap.etl.common.plugin.Caller$1.call(Caller.java:30)
  at io.cdap.cdap.etl.common.plugin.ExceptionWrappingCaller.call(ExceptionWrappingCaller.java:62)
  ... 10 common frames omitted
  

POST v3/namespaces/{namespace-id}/apps/{app-id}/workflows/DataPipelineWorkflow/runs/{run-id}/classify

[
{
  "stageName": "GCS Argument Setter",
  "errorCategory": "Plugin-'GCS Argument Setter'",
  "errorReason": "Could not parse response from 'io.cdap.plugin.gcp.gcs.GCSPath@7b0634ba': com.google.gson.stream.MalformedJsonException: Unterminated array at line 8 column 6 path $.arguments[1]",
  "errorMessage": "Could not parse response from 'io.cdap.plugin.gcp.gcs.GCSPath@7b0634ba': com.google.gson.stream.MalformedJsonException: Unterminated array at line 8 column 6 path $.arguments[1]",
  "errorType": "USER",
  "dependency": "false"
}
]