All pull requests

Pull requests

• [FLINK-41050] Canary health checks revert canary metadata changes and restart a healthy operator

  #1227·Dennis-Mircea opened Oct 20, 2026Contributor·1 task·

  ·

• [FLINK-37751][autoscaler] Add vertex name to the autoscaler scaling metrics

  #1226·Admaing opened Oct 20, 2026·1 task done·

  ·

• [FLINK-41035] Operator health probe reports "All informers are unhealthy" when a single event source fails with stop-on-informer-error=false

  #1225·Dennis-Mircea opened Oct 19, 2026Contributor·1 task·

  ·

• [FLINK-41031] Close operator-owned resources on shutdown and exit on startup failure

  #1224·Dennis-Mircea opened Oct 19, 2026Contributor·1 task·

  ·

• [FLINK-40861] Add FlinkMiniCluster CRD and API types

  #1223·dalelane opened Oct 17, 2026Contributor·1 task done·

  ·

• [FLINK-40992][operator] Allow the job parallelism to take effect when TaskManager replicas are set

  #1222·laughingman7743 opened Oct 14, 2026·1 task done·

  ·

• [FLINK-40991][operator] Read the legacy ClusterHealthInfo healthy field

  #1221·laughingman7743 opened Oct 14, 2026·1 task done·

  ·

• [FLINK-40944][operator] Pin -XX:ActiveProcessorCount to the CPU request when a CPU limit factor is set

  #1220·eskabetxe opened Oct 7, 2026Member·1 task done·

  ·
  1

• [FLINK-40407] Add reason tags to the autoscaler.scalings counter

  #1219·kaustubhbutte17 opened Oct 2, 2026·

  ·

• [FLINK-40405] Add reason tags to the autoscaler.balanced counter

  #1218·kaustubhbutte17 opened Oct 2, 2026·

  ·
  1

• [FLINK-40810] Clear the job not found error once the job is found again

  #1215·sqd opened Sep 25, 2026·1 task done·

  ·
  1

• [FLINK-40709] Add allowlist to exempt trusted hosts from jarURI restricted-host check

  #1214·spuru9 opened Sep 21, 2026Contributor·1 task done·

  ·

• [FLINK-40706] Recognize IPv6 unique local addresses in JarUriValidationUtils

  #1213·spuru9 opened Sep 18, 2026Contributor·1 task done·

  ·
  1

• [FLINK-38798] Publish a Helm provenance file for the operator chart

  #1210·Admaing opened Sep 16, 2026·

  ·
  1

• [FLINK-40542] Block session cluster deletion when running jobs cannot be determined

  #1202·spuru9 opened Sep 2, 2026Contributor·1 task done·

  ·
  7

• [hotfix] Replace deprecated Flink, JOSDK, and fabric8 APIs

  #1197·Dennis-Mircea opened Aug 28, 2026Contributor·1 task·

  ·
  12

• [FLINK-40452] Cap exception fetching by size instead of line count

  #1194·mbalassi opened Aug 26, 2026Contributor·1 task done·

  ·
  5

• [FLINK-40461] Add config option for labels on operator generated events

  #1192·csviri opened Aug 24, 2026Contributor·1 task done·

  ·

• Testing operator with next minor version of JOSDK

  #1190·csviri opened Aug 21, 2026Contributor·

  ·

• [FLINK-40445] Autoscaler: integration test for Kafka/Pulsar source partition-metric detection

  #1189·spuru9 opened Aug 20, 2026Contributor·1 task done·

  ·
  8

• [FLINK-40448] Pin resolved address during operator artifact fetch to prevent DNS rebinding

  #1188·spuru9 opened Aug 20, 2026Contributor·1 task done·

  ·

• [FLINK-40384][snapshot] Only clean up terminal snapshots

  #1185·litiliu opened Aug 19, 2026·1 task done·

  ·

• [FLINK-40372][metrics] Unregister JOSDK resource metrics after cleanup

  #1175·litiliu opened Aug 12, 2026·1 task done·

  ·
  6

• [FLINK-39554] Support multiple custom autoscaler evaluators with deterministic ordering

  #1174·Dennis-Mircea opened Aug 12, 2026Contributor·1 task done·

  ·

• [FLINK-40365][docs] Correct savepoint config requirements

  #1173·dalelane opened Aug 11, 2026Contributor·1 task·

  ·
  9