Resetting the Flink job

You must then reset the Apache Flink job.

Before you begin

Remember: Make sure that the jq command-line JSON processor is installed. The jq tool is available from this page: https://stedolan.github.io/jq/.

Procedure

  1. Retrieve the Kubernetes running jobs.
    kubectl get jobs
    This command returns the Case Flink job named <bai-release-name>-bai-icm.
  2. Reset the bai-icm job.
    kubectl get job <bai-release-name>-bai-icm  -o json | jq "del(.spec.selector)" | jq "del(.spec.template.metadata.labels)" | kubectl replace --force -f -
    For example:
    kubectl get job mybaidev-bai-icm -o json | jq "del(.spec.selector)" | jq "del(.spec.template.metadata.labels)" | kubectl replace --force -f -

Results

The commands delete the Case Flink job and re-create it by ignoring any existing checkpoint and savepoint.