bijection flink

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.

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

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

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

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

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

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

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

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

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