Sign in
apache
/
flink-kubernetes-operator
/
HEAD
91f543f
[FLINK-40402] Harden job artifact fetching against slow-host reconcile-thread exhaustion (#1186)
by Purushottam Sinha
· 22 hours ago
main
3d8940b
[FLINK-40443] Harden autoscaler metrics name parsing against complex regex (#1187)
by Purushottam Sinha
· 2 days ago
dd2faf9
[FLINK-40414] Autoscaler state ConfigMap is treated as trusted input (#1184)
by Dennis-Mircea Ciupitu
· 3 days ago
39de41c
[FLINK-40400] Harden job artifact fetching in kubernetes operator (#1180)
by Purushottam Sinha
· 3 days ago
f54ceaa
[FLINK-40408] Fix NOTICE files to match dependencies (#1182)
by Mate Czagany
· 3 days ago
e94691a
[FLINK-40413] Autoscaling example classes leak into the operator javadoc site (#1183)
by Dennis-Mircea Ciupitu
· 3 days ago
82b0562
[FLINK-40401] Harden autoscaler state deserialization in kubernetes operator. Bound decompressed data size. (#1181)
by Purushottam Sinha
· 3 days ago
bf50b35
[release] doc updates
by Gyula Fora
· 8 days ago
0494f67
[release] Update version to 1.17-SNAPSHOT
by Gyula Fora
· 8 days ago
c305a7c
[FLINK-40389] Source parallelism is not capped at the partition count (#1179)
by Dennis-Mircea Ciupitu
· 8 days ago
5ca04ac
[FLINK-40246] Migrate logging stack to SLF4J 2.x and bump Logback to 1.5.34 (#1170)
by Purushottam Sinha
· 9 days ago
5f1780e
[FLINK-40380] Document the runtime configuration and stop jobs from overriding operator config through it (#1178)
by Dennis-Mircea Ciupitu
· 9 days ago
e3db28e
[FLINK-40374] Fix redeploy-from-savepoint for suspended jobs (#1176)
by Dale Lane
· 9 days ago
163497a
[FLINK-40375] Fix kube-apiserver and mock-server tests silently skipped (#1177)
by Purushottam Sinha
· 9 days ago
fdfcc69
[FLINK-35746][Kubernetes-Operator] Add getJobConfiguration and getJobCheckpointConfiguration (#1000)
by Nishita Pattanayak
· 11 days ago
a8407c4
[FLINK-39791][helm] Honor defaultConfiguration.config.yaml and always mount config.yaml (#1126)
by Gerk Elznik
· 11 days ago
691d6ff
[FLINK-40341] Bump jackson-bom to 2.21.5 (#1171)
by Purushottam Sinha
· 2 weeks ago
ac2245a
[FLINK-39356] Fix NPE during FlinkStateSnapshot cleanup when status is null (#1169)
by Nihar Rao
· 2 weeks ago
0b7fc32
[FLINK-40055] Serialize managed cluster config in the target Flink version's YAML dialect (#1152)
by Gerk Elznik
· 2 weeks ago
6109dfd
[FLINK-39881] Add AGENTS.md and generative AI tooling disclosure to PR template (#1133)
by Purushottam Sinha
· 2 weeks ago
492e14d
[FLINK-40164] Complete the suspend when the cancellation is observed (#1168)
by Milind L
· 2 weeks ago
8e567a5
[FLINK-39953] Fix cluster deletion timeout silently swallowed during upgrade (#1138)
by Lucas Gameiro
· 3 weeks ago
0ee5111
[FLINK-40162] Handle UpgradeFailureException in FlinkSessionJobController (#1166)
by Milind L
· 3 weeks ago
266f841
[FLINK-39571][docs] Improve Flink Kubernetes Operator documentation coverage (#1164)
by Dennis-Mircea Ciupitu
· 3 weeks ago
6e9caeb
[FLINK-40103] Bump JOSDK to 5.5.0 (#1061)
by Attila Mészáros
· 5 weeks ago
332ef26
[FLINK-40155][helm] Run chart CI and e2e tests on Helm 4
by Purushottam Sinha
· 5 weeks ago
16280db
[FLINK-40119] Reset deploymentReadyTimestamp on abort to prevent premature blue delete on next deploy (#1159)
by Farooq Qaiser
· 5 weeks ago
567ac1c
[FLINK-40092] Finalize BlueGreen transition after deleting previous deployment (#1154)
by Farooq Qaiser
· 5 weeks ago
249dc9c
[FLINK-38795] Support Flink 2.0+ HA in standalone mode
by Marc Demierre
· 6 weeks ago
cb3fc9d
[hotfix] Fix typos in operator documentation, comments and scripts (#1148)
by Purushottam Sinha
· 6 weeks ago
a05d2f6
[FLINK-40104] Logging framework JARs are placed under /log instead of the operator lib directory
by Dennis-Mircea Ciupitu
· 6 weeks ago
bc92989
[FLINK-40106] Move FlinkResourceValidator and FlinkResourceMutator to the api module
by Dennis-Mircea Ciupitu
· 6 weeks ago
a0bd63a
[FLINK-40107] Group example modules under an examples aggregator pom
by Dennis-Mircea Ciupitu
· 6 weeks ago
63b57d9
[hotfix] Cleanup api compatibility test execution
by Gyula Fora
· 6 weeks ago
5dddcdc
[FLINK-39959] Improve the autoscaler context structure and propagation
by Dennis-Mircea Ciupitu
· 7 weeks ago
180c135
[FLINK-39938] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler
by Dennis-Mircea Ciupitu
· 7 weeks ago
4d7bc13
[hotfix][ci] Replace disallowed azure/setup-helm action with a direct Helm download (#1151)
by Dennis-Mircea Ciupitu
· 7 weeks ago
5350465
[FLINK-39967] Fix `backoffLimit=-1` to mean unlimited retries in FlinkStateSnapshot
by Santwana Verma
· 9 weeks ago
d131b70
[FLINK-33548] Replace taskManager/jobmanager.resource with resources conforming to ResourceRequirements
by Santwana Verma
· 9 weeks ago
d971aa3
[FLINK-39958] Autoscaler Flink REST client timeout is silently overridden by the operator client timeout (#1141)
by Dennis-Mircea Ciupitu
· 9 weeks ago
bd4bd35
[FLINK-39853][test] Upgrade Testcontainers to 2.0.5 and remove JUnit 4 dependency
by Purushottam Sinha
· 9 weeks ago
8e86db3
[hotfix][api] Remove unused Diffable markers from spec/status types (#1142)
by Dennis-Mircea Ciupitu
· 9 weeks ago
44027b9
[FLINK-39555] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler
by Dennis-Mircea Ciupitu
· 9 weeks ago
5387684
[hotfix] Auto-generate CRDs during the Maven build
by Santwana Verma
· 9 weeks ago
bdd2ff3
[hotfix] Regenerate CRDs with new Fabric8 generator
by Santwana Verma
· 9 weeks ago
30928cb
[FLINK-39511][autoscaler] FLIP-514: Custom Evaluator plugin for Flink Autoscaler
by Dennis-Mircea Ciupitu
· 9 weeks ago
17fd0f7
[FLINK-XXXXX][autoscaler] Custom Evaluator plugin for Flink Autoscaler
by Pradeepta Choudhury
· 4 months ago
d4e583d
[FLINK-39743] [flink-autoscaler] Fix incorrect expected processing rate computation
by Devika Sudheer
· 9 weeks 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
· 2 months ago
e4c56b2
[FLINK-39688] Share a single PluginManager across operator and webhook startup (#1112)
by Dennis-Mircea Ciupitu
· 3 months ago
f5186b4
[FLINK-39838] Bump Flink version to 1.20.4 (#1131)
by Purushottam Sinha
· 3 months ago
271e269
[FLINK-39752] Use same event recorder instance
by Dennis-Mircea Ciupitu
· 3 months ago
6ef7779
[hotfix] Correct fabric8 version to 7.3.1 in NOTICE files (#1130)
by Purushottam Sinha
· 3 months ago
34edcc4
[FLINK-39826][autoscaler] Strengthen autoscaler configuration validation (#1129)
by Dennis-Mircea Ciupitu
· 3 months ago
955d2be
[hotfix][test] Finalize JUnit 5 migration and prune unused test dependencies (#1119)
by Purushottam Sinha
· 3 months ago
f4c0c99
[FLINK-39808] Warn on use of deprecated Flink versions (#1124)
by Dennis-Mircea Ciupitu
· 3 months ago
95fc69a
[FLINK-39819] Avoid redundant JSON String round-trips in SpecUtils.clone and DiffResult.toString (#1128)
by Dennis-Mircea Ciupitu
· 3 months ago
3722d22
[FLINK-39814] Honor FlinkSessionJob savepoint dir in snapshots
by lrsb
· 3 months ago
c45121a
[FLINK-39216][helm] Add PKCS12 profile option for webhook certificate (#1118)
by Breno Ferreira
· 3 months ago
ccebc63
[FLINK-39691] Fix toString for AggregatedMetric
by Pavel Zeger
· 3 months ago
83c2d35
[FLINK-39692][Kubernetes-Operator] Include caught exceptions in warn/error log statements (#1116)
by Pavel Zeger
· 3 months ago
13c867c
[FLINK-39713] Bump log4j, jackson, and Beam to retire CVEs
by Purushottam Sinha
· 3 months ago
fb73048
[htofix] Change the Context type from CR to ?
by Dennis-Mircea Ciupitu
· 3 months ago
8fb8288
[hotfix] Clean up FlinkBlueGreenDeploymentController
by Dennis-Mircea Ciupitu
· 3 months ago
c44a881
[hotfix] Reuse FlinkConfigManager#isSnapshotCrdInstalled in controllers
by Dennis-Mircea Ciupitu
· 3 months ago
ac1b135
[FLINK-39646][examples] Update python example to Flink 2.2 (#1111)
by Aleksandr Savonin
· 3 months ago
42737fc
[FLINK-39618] FlinkDeployment deletion deadlocks when FlinkSessionJobs are running with default block-on-* options
by Dennis-Mircea Ciupitu
· 4 months ago
775b577
[release] Update version to 1.16-SNAPSHOT
by Gyula Fora
· 4 months ago
7e99784
[hotfix] Add missing compatibility checks (#1108)
by Gyula Fora
· 4 months ago
8de5c0b
[hotfix][e2e] Mitigate flaky minikube ingress addon enable in CI (#1107)
by Dennis-Mircea Ciupitu
· 4 months ago
640b436
[hotfix][autoscaler] Cover ScalingRealizer override application with tests (#1075)
by Dennis-Mircea Ciupitu
· 4 months ago
e3e0cbe
[FLINK-39559] Set ownerReferences on JM Deployment recreated during session recovery
by Krzysztof Adrian Palka
· 4 months ago
9099abd
[FLINK-39501] Logback Support in Flink Kubernetes Operator
by Dennis-Mircea Ciupitu
· 4 months ago
90a7faf
[FLINK-37766] FlinkSessionJob deletion blocked by finalizer
by Prashant Khanal
· 4 months ago
a00bf27
[hotfix] Clear stale savepointTriggerId on B/G transition abort
by jennifer-xiong25
· 4 months ago
add7fb3
[hotfix] Validate jarURI in DefaultValidator
by Andrea Cosentino
· 4 months ago
3246630
[FLINK-39507] Terminal jobs should never be restarted by cluster/job health check
by Gyula Fora
· 4 months ago
32808fe
[hotfix] Fix missing log in AbstractFlinkService
by GuoYu
· 4 months ago
230611a
[FLINK-39541] Improve operator metrics documentation and bundle additional metric reporters
by Dennis-Mircea Ciupitu
· 4 months ago
d997345
[hotfix][docs] Fix Custom Flink Resource Mutators documentation code section (#1100)
by Dennis-Mircea Ciupitu
· 4 months ago
c6769c7
[FLINK-39508][flink-kubernetes-webhook] Fix flink-kubernetes-webhook module tests
by Dennis-Mircea Ciupitu
· 4 months ago
c63cd67
[hotfix][docs] Sync Chinese helm and upgrade with English (#1091)
by Purushottam Sinha
· 4 months ago
0a94e1f
[hotfix] Fix broken stable docs URL in outdated/unreleased banner (#1092)
by Purushottam Sinha
· 4 months ago
e2475aa
[hotfix][examples] Update example JAR URLs from Flink 1.16.1 to Flink 2.2.0 (#1095)
by Dennis-Mircea Ciupitu
· 4 months ago
24b0d99
[FLINK-39509][flink-kubernetes-webhook] Fix mutating webhook producing spurious object modifications on no-op patches
by Dennis-Mircea Ciupitu
· 4 months ago
27f66d9
[hotfix][docs] Fix Helm broken table documentation page
by Dennis-Mircea Ciupitu
· 4 months ago
04065a0
[FLINK-39439] Fix savepoint history entry removed from status before dispose succeeds
by Gabor Somogyi
· 4 months ago
cdc568c
[FLINK-39271] Fix session job cleanup with unaccessible session cluster
by Gyula Fora
· 6 months ago
02fa1ab
[FLINK-39271] Harden session job deletion flow
by Gyula Fora
· 6 months ago
a6fb727
[hotfix] Fix docker build actions
by Gyula Fora
· 4 months ago
896590b
[FLINK-39432] Add option to delete with session running session jobs
by Gyula Fora
· 4 months ago
c046a80
[FLINK-39270] Fix savepoint/last-state upgrade state loss under slow JM
by Gyula Fora
· 6 months ago
0a4d841
[FLINK-39220] Add unit tests for ConditionsUtils (#1068)
by Harshit Gupta
· 4 months ago
93b6960
[hotfix] Update docs to include v2.2 as supported and clean deprecated versions
by Michał Kozal
· 5 months ago
2d4c992
[hotfix][docs] Document deprecation of target.utilization.boundary in favor of utilization.max / utilization.min
by Dennis-Mircea Ciupitu
· 5 months ago
bc7c562
[hotfix] Avoid unnecessary scale-down when recommended parallelism equals current parallelism in delay window.
by wangxinglong02
· 5 months ago
14f0403
[FLINK-39299][flink-autoscaler] Inconsistent vertex parallelism alignment logic
by Dennis-Mircea Ciupitu
· 5 months ago
56af6bf
[FLINK-33634] Add Conditions to Flink CRD's Status field (#1064)
by David Radley
· 6 months ago
f0c9aac
Install yamale to allow linting to work (#1067)
by David Radley
· 6 months ago
5d48335
[FLINK-39177] Enable Flink 2.2 tests and bump example flink versions
by Gyula Fora
· 6 months ago
Next »