> ## Documentation Index
> Fetch the complete documentation index at: https://docs.bijection.com/llms.txt
> Use this file to discover all available pages before exploring further.

# bijection flink

> Prepare, inspect and control customer Flink executions

## bijection flink

```text theme={"theme":{"light":"github-light-default","dark":"github-dark-default"}}
Prepare, inspect and control customer Flink executions

Usage:
  bijection flink [flags]
  bijection flink [command]

Available Commands:
  check       Check broker, native archive and Iceberg bindings read-only
  lock        Pin the installed adapter and its exact dependency classpath
  observe     Recover publication observation without submitting compute
  recover     Restore a stopped job from its last accepted checkpoint
  replay-plan Inventory every occurrence in the exact retained native archive range
  rescale     Cancel the old job and restore accepted state at the configured parallelism
  run         Submit or recover a customer Flink job and publish checkpoint boundaries
  status      Inspect this job's continuity and settled checkpoint
  stop        Stop this job and release only its private output branches

Flags:
  -h, --help       help for flink
      --help-all   Show all commands and options, including administrative controls.

Use "bijection flink [command] --help" for more information about a command.
```

## bijection flink check

```text theme={"theme":{"light":"github-light-default","dark":"github-dark-default"}}
Check broker, native archive and Iceberg bindings read-only

Usage:
  bijection flink check [flags]

Flags:
      --artifact string         Captured Flink program JSON
      --connection string       Private installed Flink connection JSON
      --continuity string       Continuous execution identity
      --grant string            Private pipeline producer grant
  -h, --help                    help for check
      --help-all                Show all commands and options, including administrative controls.
      --job string              Fixed Flink job identity
      --previous-state string   Prior settled controller state for replacement
      --restore string          Exact completed externalized checkpoint path
      --state string            Private durable controller directory
```

## bijection flink lock

```text theme={"theme":{"light":"github-light-default","dark":"github-dark-default"}}
Pin the installed adapter and its exact dependency classpath

Usage:
  bijection flink lock [flags]

Flags:
  -h, --help            help for lock
      --help-all        Show all commands and options, including administrative controls.
      --output string   New runtime lock file
```

## bijection flink observe

```text theme={"theme":{"light":"github-light-default","dark":"github-dark-default"}}
Recover publication observation without submitting compute

Usage:
  bijection flink observe [flags]

Flags:
      --artifact string         Captured Flink program JSON
      --connection string       Private installed Flink connection JSON
      --continuity string       Continuous execution identity
      --grant string            Private pipeline producer grant
  -h, --help                    help for observe
      --help-all                Show all commands and options, including administrative controls.
      --job string              Fixed Flink job identity
      --previous-state string   Prior settled controller state for replacement
      --restore string          Exact completed externalized checkpoint path
      --state string            Private durable controller directory
```

## bijection flink recover

```text theme={"theme":{"light":"github-light-default","dark":"github-dark-default"}}
Restore a stopped job from its last accepted checkpoint

Usage:
  bijection flink recover [flags]

Flags:
      --artifact string         Captured Flink program JSON
      --connection string       Private installed Flink connection JSON
      --continuity string       Continuous execution identity
      --grant string            Private pipeline producer grant
  -h, --help                    help for recover
      --help-all                Show all commands and options, including administrative controls.
      --job string              Fixed Flink job identity
      --previous-state string   Prior settled controller state for replacement
      --restore string          Exact completed externalized checkpoint path
      --state string            Private durable controller directory
```

## bijection flink replay-plan

```text theme={"theme":{"light":"github-light-default","dark":"github-dark-default"}}
Inventory every occurrence in the exact retained native archive range

Usage:
  bijection flink replay-plan [flags]

Flags:
      --artifact string         Captured Flink program JSON
      --connection string       Private installed Flink connection JSON
      --continuity string       Continuous execution identity
      --grant string            Private pipeline producer grant
  -h, --help                    help for replay-plan
      --help-all                Show all commands and options, including administrative controls.
      --job string              Fixed Flink job identity
      --previous-state string   Prior settled controller state for replacement
      --restore string          Exact completed externalized checkpoint path
      --state string            Private durable controller directory
```

## bijection flink rescale

```text theme={"theme":{"light":"github-light-default","dark":"github-dark-default"}}
Cancel the old job and restore accepted state at the configured parallelism

Usage:
  bijection flink rescale [flags]

Flags:
      --artifact string         Captured Flink program JSON
      --connection string       Private installed Flink connection JSON
      --continuity string       Continuous execution identity
      --grant string            Private pipeline producer grant
  -h, --help                    help for rescale
      --help-all                Show all commands and options, including administrative controls.
      --job string              Fixed Flink job identity
      --previous-state string   Prior settled controller state for replacement
      --restore string          Exact completed externalized checkpoint path
      --state string            Private durable controller directory
```

## bijection flink run

```text theme={"theme":{"light":"github-light-default","dark":"github-dark-default"}}
Submit or recover a customer Flink job and publish checkpoint boundaries

Usage:
  bijection flink run [flags]

Flags:
      --artifact string         Captured Flink program JSON
      --connection string       Private installed Flink connection JSON
      --continuity string       Continuous execution identity
      --grant string            Private pipeline producer grant
  -h, --help                    help for run
      --help-all                Show all commands and options, including administrative controls.
      --job string              Fixed Flink job identity
      --previous-state string   Prior settled controller state for replacement
      --restore string          Exact completed externalized checkpoint path
      --state string            Private durable controller directory
```

## bijection flink status

```text theme={"theme":{"light":"github-light-default","dark":"github-dark-default"}}
Inspect this job's continuity and settled checkpoint

Usage:
  bijection flink status [flags]

Flags:
      --connection string   Private Flink connection JSON
      --grant string        Private pipeline producer grant
  -h, --help                help for status
      --help-all            Show all commands and options, including administrative controls.
      --state string        Private durable controller directory
```

## bijection flink stop

```text theme={"theme":{"light":"github-light-default","dark":"github-dark-default"}}
Stop this job and release only its private output branches

Usage:
  bijection flink stop [flags]

Flags:
      --connection string   Private installed Flink connection JSON
      --grant string        Private pipeline producer grant
  -h, --help                help for stop
      --help-all            Show all commands and options, including administrative controls.
      --state string        Private durable controller directory
```


This documentation is built and hosted on [Mintlify](https://mintlify.com), a developer documentation platform.