Sign in
◑
Theme
apache
/
flink-kubernetes-operator
/
HEAD
43719c9
[FLINK-40991][operator] Ignore unknown fields when reading ClusterHealthInfo (#1221)
by laughingman7743
· 2 days ago
main
b0adeed
[FLINK-40365][docs] Correct savepoint config requirements (#1173)
by Dale Lane
· 2 days ago
c9d33c8
[FLINK-41222][autoscaler] Accept a conflicting ConfigMap write that Kubernetes already applied (#1234)
by Alex Kukhar
· 3 days ago
581c67e
[FLINK-41031] Close operator-owned resources on shutdown and exit on startup failure (#1224)
by Dennis-Mircea Ciupitu
· 3 days ago
5bcc06f
[FLINK-41050] Canary health checks revert canary metadata changes and restart a healthy operator (#1227)
by Dennis-Mircea Ciupitu
· 3 days ago
88f68e4
[FLINK-41242] Report the original exception class in `status.error` (#1233)
by Santwana Verma
· 3 days ago
6eb5d9c
[FLINK-37448] Report actual TaskManager count in `status.taskManager.replicas` (#1146)
by Santwana Verma
· 4 days ago
284a8d0
[FLINK-40470] Record spec before deployment attempt in savepoint redeploy (#1216)
by 김현
· 4 weeks ago
f5456a4
[FLINK-40857] Fix StatusRecorder not breaking out of for loop
by Mate Czagany
· 4 weeks ago
de630f6
Revert "[FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration (#1000)"
by Gyula Fora
· 6 weeks ago
c1ca49e
Revert "[FLINK-40380] Document the runtime configuration and stop jobs from overriding operator config through it (#1178)"
by Gyula Fora
· 6 weeks ago
8f95987
Revert "[FLINK-40465] Add version-independent classes to parse job config (#1193)"
by Gyula Fora
· 6 weeks ago
776fdd7
Revert "[FLINK-40583] Filter operator keys on the remaining runtime config paths"
by Gyula Fora
· 6 weeks ago
73398a7
[hotfix] Remove redundant autoscaler Plugin discovery (#1198)
by Dennis-Mircea Ciupitu
· 7 weeks ago
c6098b0
[FLINK-40535] Standalone session clusters are redeployed instead of scaled in-place
by Dennis-Mircea Ciupitu
· 7 weeks ago
56ddd05
[FLINK-40467] Randomise application result store paths
by Dale Lane
· 7 weeks ago
56b8817
[FLINK-40550] Fix operator crash when reconcile.parallelism is -1
by Purushottam Sinha
· 7 weeks ago
98f1be9
[FLINK-40581] Fix examples that cannot run against their declared Flink version
by Dennis-Mircea Ciupitu
· 7 weeks ago
0f66927
[FLINK-40558] Apply in-place scaling only on SCALE spec diff type
by Dennis-Mircea Ciupitu
· 7 weeks ago
d407c02
[FLINK-40583] Filter operator keys on the remaining runtime config paths
by Dennis-Mircea Ciupitu
· 7 weeks ago
59a6ffd
[FLINK-40587] Recreating a FlinkDeployment throws an autoscaler exception
by Dennis-Mircea Ciupitu
· 7 weeks ago
4e72aa9
[hotfix] Fix E2E tests
by Dennis-Mircea Ciupitu
· 7 weeks ago
4448af0
[hotfix] Add missing reflectasm dependency to NOTICE files
by Dennis-Mircea Ciupitu
· 7 weeks ago
38a9f19
[FLINK-40474] Autoscaler parallelism overrides serialized in the operator's YAML dialect break job submission for Flink 1.x jobs (#1195)
by Dennis-Mircea Ciupitu
· 9 weeks ago
3ed982e
[FLINK-40465] Add version-independent classes to parse job config (#1193)
by Mate Czagany
· 9 weeks ago
4a4b85d
[FLINK-38290][operator] Keep terminal job state when job is not found
by Royston
· 9 weeks ago
91f543f
[FLINK-40402] Harden job artifact fetching against slow-host reconcile-thread exhaustion (#1186)
by Purushottam Sinha
· 2 months ago
3d8940b
[FLINK-40443] Harden autoscaler metrics name parsing against complex regex (#1187)
by Purushottam Sinha
· 2 months ago
dd2faf9
[FLINK-40414] Autoscaler state ConfigMap is treated as trusted input (#1184)
by Dennis-Mircea Ciupitu
· 2 months ago
39de41c
[FLINK-40400] Harden job artifact fetching in kubernetes operator (#1180)
by Purushottam Sinha
· 2 months ago
f54ceaa
[FLINK-40408] Fix NOTICE files to match dependencies (#1182)
by Mate Czagany
· 2 months ago
e94691a
[FLINK-40413] Autoscaling example classes leak into the operator javadoc site (#1183)
by Dennis-Mircea Ciupitu
· 2 months ago
82b0562
[FLINK-40401] Harden autoscaler state deserialization in kubernetes operator. Bound decompressed data size. (#1181)
by Purushottam Sinha
· 2 months ago
bf50b35
[release] doc updates
by Gyula Fora
· 3 months ago
0494f67
[release] Update version to 1.17-SNAPSHOT
by Gyula Fora
· 3 months ago
c305a7c
[FLINK-40389] Source parallelism is not capped at the partition count (#1179)
by Dennis-Mircea Ciupitu
· 3 months ago
5ca04ac
[FLINK-40246] Migrate logging stack to SLF4J 2.x and bump Logback to 1.5.34 (#1170)
by Purushottam Sinha
· 3 months ago
5f1780e
[FLINK-40380] Document the runtime configuration and stop jobs from overriding operator config through it (#1178)
by Dennis-Mircea Ciupitu
· 3 months ago
e3db28e
[FLINK-40374] Fix redeploy-from-savepoint for suspended jobs (#1176)
by Dale Lane
· 3 months ago
163497a
[FLINK-40375] Fix kube-apiserver and mock-server tests silently skipped (#1177)
by Purushottam Sinha
· 3 months ago
fdfcc69
[FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration (#1000)
by Nishita Pattanayak
· 3 months ago
a8407c4
[FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml (#1126)
by Gerk Elznik
· 3 months ago
691d6ff
[FLINK-40341] Bump jackson-bom to 2.21.5 (#1171)
by Purushottam Sinha
· 3 months ago
ac2245a
[FLINK-39356] Fix NPE during FlinkStateSnapshot cleanup when status is null (#1169)
by Nihar Rao
· 3 months ago
0b7fc32
[FLINK-40055] Serialize managed cluster config in the target Flink version's YAML dialect (#1152)
by Gerk Elznik
· 3 months ago
6109dfd
[FLINK-39881] Add AGENTS.md and generative AI tooling disclosure to PR template (#1133)
by Purushottam Sinha
· 3 months ago
492e14d
[FLINK-40164] Complete the suspend when the cancellation is observed (#1168)
by Milind L
· 3 months ago
8e567a5
[FLINK-39953] Fix cluster deletion timeout silently swallowed during upgrade (#1138)
by Lucas Gameiro
· 3 months ago
0ee5111
[FLINK-40162] Handle UpgradeFailureException in FlinkSessionJobController (#1166)
by Milind L
· 3 months ago
266f841
[FLINK-39571][docs] Improve Flink Kubernetes Operator documentation coverage (#1164)
by Dennis-Mircea Ciupitu
· 3 months ago
6e9caeb
[FLINK-40103] Bump JOSDK to 5.5.0 (#1061)
by Attila Mészáros
· 3 months ago
332ef26
[FLINK-40155][helm] Run chart CI and e2e tests on Helm 4
by Purushottam Sinha
· 4 months ago
16280db
[FLINK-40119] Reset deploymentReadyTimestamp on abort to prevent premature blue delete on next deploy (#1159)
by Farooq Qaiser
· 4 months ago
567ac1c
[FLINK-40092] Finalize BlueGreen transition after deleting previous deployment (#1154)
by Farooq Qaiser
· 4 months ago
249dc9c
[FLINK-38795] Support Flink 2.0+ HA in standalone mode
by Marc Demierre
· 4 months ago
cb3fc9d
[hotfix] Fix typos in operator documentation, comments and scripts (#1148)
by Purushottam Sinha
· 4 months ago
a05d2f6
[FLINK-40104] Logging framework JARs are placed under /log instead of the operator lib directory
by Dennis-Mircea Ciupitu
· 4 months ago
bc92989
[FLINK-40106] Move FlinkResourceValidator and FlinkResourceMutator to the api module
by Dennis-Mircea Ciupitu
· 4 months ago
a0bd63a
[FLINK-40107] Group example modules under an examples aggregator pom
by Dennis-Mircea Ciupitu
· 4 months ago
63b57d9
[hotfix] Cleanup api compatibility test execution
by Gyula Fora
· 4 months ago
5dddcdc
[FLINK-39959] Improve the autoscaler context structure and propagation
by Dennis-Mircea Ciupitu
· 4 months ago
180c135
[FLINK-39938] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler
by Dennis-Mircea Ciupitu
· 4 months ago
4d7bc13
[hotfix][ci] Replace disallowed azure/setup-helm action with a direct Helm download (#1151)
by Dennis-Mircea Ciupitu
· 4 months ago
5350465
[FLINK-39967] Fix `backoffLimit=-1` to mean unlimited retries in FlinkStateSnapshot
by Santwana Verma
· 4 months ago
d131b70
[FLINK-33548] Replace taskManager/jobmanager.resource with resources conforming to ResourceRequirements
by Santwana Verma
· 4 months ago
d971aa3
[FLINK-39958] Autoscaler Flink REST client timeout is silently overridden by the operator client timeout (#1141)
by Dennis-Mircea Ciupitu
· 4 months ago
bd4bd35
[FLINK-39853][test] Upgrade Testcontainers to 2.0.5 and remove JUnit 4 dependency
by Purushottam Sinha
· 4 months ago
8e86db3
[hotfix][api] Remove unused Diffable markers from spec/status types (#1142)
by Dennis-Mircea Ciupitu
· 4 months ago
44027b9
[FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler
by Dennis-Mircea Ciupitu
· 4 months ago
5387684
[hotfix] Auto-generate CRDs during the Maven build
by Santwana Verma
· 5 months ago
bdd2ff3
[hotfix] Regenerate CRDs with new Fabric8 generator
by Santwana Verma
· 5 months ago
30928cb
[FLINK-39511][autoscaler] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
by Dennis-Mircea Ciupitu
· 5 months ago
17fd0f7
[FLINK-XXXXX][autoscaler] Custom Evaluator plugin for Flink Autoscaler
by Pradeepta Choudhury
· 6 months ago
d4e583d
[FLINK-39743] [flink-autoscaler] Fix incorrect expected processing rate computation
by Devika Sudheer
· 5 months ago
0c70975
[FLINK-39306][flink-autoscaler] Align the busy-time TRUE_PROCESSING_RATE numerator estimator with the busy-time aggregator (#1078)
by Dennis-Mircea Ciupitu
· 5 months ago
e4c56b2
[FLINK-39688] Share a single PluginManager across operator and webhook startup (#1112)
by Dennis-Mircea Ciupitu
· 5 months ago
f5186b4
[FLINK-39838] Bump Flink version to 1.20.4 (#1131)
by Purushottam Sinha
· 5 months ago
271e269
[FLINK-39752] Use same event recorder instance
by Dennis-Mircea Ciupitu
· 5 months ago
6ef7779
[hotfix] Correct fabric8 version to 7.3.1 in NOTICE files (#1130)
by Purushottam Sinha
· 5 months ago
34edcc4
[FLINK-39826][autoscaler] Strengthen autoscaler configuration validation (#1129)
by Dennis-Mircea Ciupitu
· 5 months ago
955d2be
[hotfix][test] Finalize JUnit 5 migration and prune unused test dependencies (#1119)
by Purushottam Sinha
· 5 months ago
f4c0c99
[FLINK-39808] Warn on use of deprecated Flink versions (#1124)
by Dennis-Mircea Ciupitu
· 5 months ago
95fc69a
[FLINK-39819] Avoid redundant JSON String round-trips in SpecUtils.clone and DiffResult.toString (#1128)
by Dennis-Mircea Ciupitu
· 5 months ago
3722d22
[FLINK-39814] Honor FlinkSessionJob savepoint dir in snapshots
by lrsb
· 5 months ago
c45121a
[FLINK-39216][helm] Add PKCS12 profile option for webhook certificate (#1118)
by Breno Ferreira
· 5 months ago
ccebc63
[FLINK-39691] Fix toString for AggregatedMetric
by Pavel Zeger
· 5 months ago
83c2d35
[FLINK-39692][Kubernetes-Operator] Include caught exceptions in warn/error log statements (#1116)
by Pavel Zeger
· 5 months ago
13c867c
[FLINK-39713] Bump log4j, jackson, and Beam to retire CVEs
by Purushottam Sinha
· 5 months ago
fb73048
[htofix] Change the Context type from CR to ?
by Dennis-Mircea Ciupitu
· 5 months ago
8fb8288
[hotfix] Clean up FlinkBlueGreenDeploymentController
by Dennis-Mircea Ciupitu
· 5 months ago
c44a881
[hotfix] Reuse FlinkConfigManager#isSnapshotCrdInstalled in controllers
by Dennis-Mircea Ciupitu
· 5 months ago
ac1b135
[FLINK-39646][examples] Update python example to Flink 2.2 (#1111)
by Aleksandr Savonin
· 6 months ago
42737fc
[FLINK-39618] FlinkDeployment deletion deadlocks when FlinkSessionJobs are running with default block-on-* options
by Dennis-Mircea Ciupitu
· 6 months ago
775b577
[release] Update version to 1.16-SNAPSHOT
by Gyula Fora
· 6 months ago
7e99784
[hotfix] Add missing compatibility checks (#1108)
by Gyula Fora
· 6 months ago
8de5c0b
[hotfix][e2e] Mitigate flaky minikube ingress addon enable in CI (#1107)
by Dennis-Mircea Ciupitu
· 6 months ago
640b436
[hotfix][autoscaler] Cover ScalingRealizer override application with tests (#1075)
by Dennis-Mircea Ciupitu
· 6 months ago
e3e0cbe
[FLINK-39559] Set ownerReferences on JM Deployment recreated during session recovery
by Krzysztof Adrian Palka
· 6 months ago
9099abd
[FLINK-39501] Logback Support in Flink Kubernetes Operator
by Dennis-Mircea Ciupitu
· 6 months ago
90a7faf
[FLINK-37766] FlinkSessionJob deletion blocked by finalizer
by Prashant Khanal
· 6 months ago
Next »