java.lang.NullPointerException error - cdc-change-applier

[abekila]

The cdc-embedeed-connector works perfectly fine so does the cdc-change-applier but in the dataflow job it constantly throws "java.lang.NullPointerException error".

Error message from worker: java.lang.NullPointerException
        com.google.cloud.dataflow.cdc.applier.BigQueryStatementIssuingFn.process(BigQueryStatementIssuingFn.java:70)

{
  "textPayload": "Error message from worker: java.lang.NullPointerException\n        com.google.cloud.dataflow.cdc.applier.BigQueryStatementIssuingFn.process(BigQueryStatementIssuingFn.java:70)",
  "insertId": "nl9mqkcd38",
  "resource": {
    "type": "dataflow_step",
    "labels": {
      "job_id": "2020-11-09_08_06_12-10849713869050811356",
      "step_id": "",
      "job_name": "cdctobigquerychangeapplierpipeline-1109160602-f171ad7",
      "region": "us-central1",
      "project_id": "xxxxx"
    }
  },
  "timestamp": "2020-11-09T16:59:19.721391316Z",
  "severity": "ERROR",
  "labels": {
    "dataflow.googleapis.com/region": "us-central1",
    "dataflow.googleapis.com/job_id": "2020-11-09_08_06_12-10849713869050811356",
    "dataflow.googleapis.com/job_name": "cdctobigquerychangeapplierpipeline"
  },
  "logName": "projects/xxx/logs/dataflow.googleapis.com%2Fjob-message",
  "receiveTimestamp": "2020-11-09T16:59:20.610597616Z"
}

[dustindoan-telus]

@abekila Were you able to find the root cause of this npe? I'm constantly seeing this error in my current deployment as well.