Google Git
Sign in
apache / flink-kubernetes-operator / HEAD
  1. 249a694 [FLINK-35105][autoscaler] Support setting default Autoscaler options at autoscaler standalone level by Rui Fan · 3 weeks ago main
  2. 9db83bc [FLINK-34980] Translate overview document into Chinese (#810) by Cancai Cai · 26 hours ago
  3. e73363f [FLINK-35278] Fix occasional NPE on getting latest resource for status replace by Ferenc Csaky · 3 days ago
  4. b1f4b3f [FLINK-35192] Remove usage of deleteOnExit() to reduce the memory usage of the operator by gengbiao.gb · 7 days ago
  5. 921bfd0 [hotfix] Using Flink ExceptionUtils#findThrowable for exception checking (#818) by Xin Hao · 9 days ago
  6. 9ea69eb [FLINK-34970] Translate architecture documents into Chinese by caicancai · 5 weeks ago
  7. baad900 [FLINK-34574] Add CPU and memory size autoscaler quota by Gabor Somogyi · 3 weeks ago
  8. 4293d58 [FLINK-31860] FlinkDeployments never finalize when namespace is deleted by zhou-jiang · 5 weeks ago
  9. 4ec4b31 [FLINK-35116] Bump fabric8 version to 6.11.0 by Marton Balassi · 3 weeks ago
  10. 29a4aa5 [FLINK-35116] Bump operator sdk version to 4.8.3 by Marton Balassi · 3 weeks ago
  11. 75eb206 [FLINK-34906][autoscaler] Only scale when all tasks are running by Rui Fan · 7 weeks ago
  12. be3b79b [FLINK-35108] Do not trigger deployment recovery for finished/failed jobs by Gyula Fora · 3 weeks ago
  13. a3ef048 [FLINK-34947] Only scale down JM in Foreground deletion propagation and reduce timeout by Gyula Fora · 6 weeks ago
  14. 8125456 [FLINK-34961] Use dedicated CI name for Kubernetes Operator to differentiate it in infra-reports by Sergey Nuyanzin · 3 weeks ago
  15. 1142644 [FLINK-34934] Translation Flink-Kubernetes-Operator document framework construction by caicancai · 6 weeks ago
  16. 9119d73 [FLINK-34957][autoscaler] Event handler records the exception stack trace when exception message is null by Rui Fan · 6 weeks ago
  17. 96f8b20 [FLINK-34538][docs] Add Autotuning documentation (#807) by Maximilian Michels · 6 weeks ago
  18. a97bc2d [hotfix] Correct the doc related to restart time tracking by Rui Fan · 7 weeks ago
  19. b584b08 [FLINK-34744][autoscaler] Fix the issue that autoscaling-dynamic cannot run by Rui Fan · 7 weeks ago
  20. 51fe002 [release] Update version to 1.9-SNAPSHOT (#798) by Maximilian Michels · 8 weeks ago
  21. 8938658 [FLINK-34619] Do not wait for scaling completion in UPGRADE state with in-place scaling (#793) by Gyula Fora · 8 weeks ago
  22. ab41083 [FLINK-34655] Copy IOMetricsInfo to `flink-autoscaler-standalone` module by Rui Fan · 8 weeks ago
  23. ede1a61 [FLINK-34524] Scale down JM deployment to 0 before deletion by Gyula Fora · 2 months ago
  24. ff7c0df [FLINK-34642] Add a test for zero lower utilization boundary (#796) by Maximilian Michels · 8 weeks ago
  25. 63d8339 [hotfix] Handle missing busy time gracefully in IOMetricsInfo by Gyula Fora · 10 weeks ago
  26. 4294616 [hotfix] Fix ineffective scaling event triggering by Gyula Fora · 9 weeks ago
  27. 726e484 [FLINK-34566] Pass a FixedThreadPool to set reconciliation parallelism correctly by fengfei02 · 9 weeks ago
  28. d526174 [FLINK-34152] Add an option to scale memory when downscaling (#786) by Maximilian Michels · 9 weeks ago
  29. b8f22bf [hotfix] Improve FlinkDeployment spec overview doc (#788) by Cancai Cai · 9 weeks ago
  30. f4b04ec [FLINK-34504][autoscaler] Avoid the parallelism adjustment when the upstream shuffle type doesn't have keyBy (#783) by Rui Fan · 2 months ago
  31. d738c57 Add helm chart repo to helm docs (#784) by Domenic Bove · 2 months ago
  32. 304fca8 [FLINK-34502][autoscaler] Support calculating network memory for forward and rescale edge (#782) by Rui Fan · 2 months ago
  33. 6a86065 [FLINK-34471] Tune network memory with memory tuning (#781) by Maximilian Michels · 2 months ago
  34. 3ead906 [FLINK-34152] Tune all directly observable memory types (except network memory) (#778) by Maximilian Michels · 2 months ago
  35. 37ca517 [FLINK-33636][autoscaler] Document the JDBC Autoscaler event handler by Rui Fan · 3 months ago
  36. c576c41 [FLINK-33636][autoscaler] Autoscaler Standalone supports the JdbcAutoScalerEventHandler by Rui Fan · 3 months ago
  37. 9fda27a [FLINK-33636][autoscaler] Support the JDBCAutoScalerEventHandler by Rui Fan · 3 months ago
  38. 7cad846 [refactor] Moving the getParallelismHashCode from KubernetesAutoScalerEventHandler to AutoScalerEventHandler by Rui Fan · 3 months ago
  39. 0a7588c [FLINK-34266][FLINK-34213] Compute Autoscaler metrics correctly over metric window by Gyula Fora · 3 months ago
  40. a8fd194 [FLINK-34438] Wait for Deployments to be deleted on cluster shutdown by Máté Czagány · 3 months ago
  41. 48692b7 [FLINK-34152] Tune heap memory of autoscaled jobs (#762) by Maximilian Michels · 3 months ago
  42. 733b1b5 [FLINK-34389][autoscaler] JdbcAutoscalerStateStore explicitly writes update_time by Rui Fan · 3 months ago
  43. 6cab745 [FLINK-34439] Move chown operations to COPY commands in Dockerfile by Mate Czagany · 3 months ago
  44. f5d9b19 [FLINK-34398] Consider FlinkSessionJob's flinkConfiguration overrides during session job spec validation by Dominik Dębowczyk · 3 months ago
  45. ecc15a3 [FLINK-33771] Extract method to estimate task slots and add dedicated test (#773) by Maximilian Michels · 3 months ago
  46. 24643c8 [FLINK-31220] Replace Pod with PodTemplateSpec for the pod template properties by Gyula Fora · 3 months ago
  47. 2bd6b1b [FLINK-34178][autoscaler] Fix the bug that observed scaling restart time is always great than `stabilization.interval` by Rui Fan · 4 months ago
  48. 746a996 [FLINK-34178][autoscaler][refactor] Get the jobRunningTs from JobStatus.RUNNING instead of max timestamp by Rui Fan · 3 months ago
  49. 398a87c [FLINK-34329][autoscaler] Fix the bug that scaling report parser doesn't support Locale by Rui Fan · 3 months ago
  50. 02d8dd5 [FLINK-33089] Clean up 1.13 and 1.14 references from docs and code (#768) by Maximilian Michels · 3 months ago
  51. ca3a746 [FLINK-34319] Bump okhttp version to 4.12.0 by ConradJam · 3 months ago
  52. 4342636 [FLINK-34311] Do not change min resource requirements when rescaling for adaptive scheduler by Gyula Fora · 3 months ago
  53. 66808eb [FLINK-34104][autoscaler] Improve the ScalingReport format of autoscaling by Rui Fan · 4 months ago
  54. 6be277c [FLINK-33006] add e2e for flink operator ha by Peter Huang · 3 months ago
  55. 0fa78d3 [FLINK-33803] Set observedGeneration at end of reconciliation by Justin Chen · 3 months ago
  56. ca55874 [FLINK-33287] Using the flink shaded jackson for flink-autoscaler by Rui Fan · 4 months ago
  57. 72231cf [FLINK-33403] Bump flink version to 1.18.1 for flink-kubernetes-operator by 1996fanrui · 6 months ago
  58. 31d01f2 [FLINK-34198] Remove e2e test operator log error check by Gabor Somogyi · 4 months ago
  59. 6e78221 [FLINK-33450][autoscaler] Document the JDBC Autoscaler State Store by Rui Fan · 4 months ago
  60. 96b2aa0 [FLINK-33450][autoscaler] StandaloneAutoscalerEntrypoint supports the JDBCAutoScalerStateStore by Rui Fan · 4 months ago
  61. 293067a [FLINK-33450][autoscaler] Support the JDBCAutoScalerStateStore by Rui Fan · 5 months ago
  62. c34fe4f [FLINK-33450][autoscaler] Extract the AbstractAutoScalerStateStoreTest and add the InMemoryAutoScalerStateStoreTest by Rui Fan · 4 months ago
  63. 775bc5f [FLINK-34131] Ensure cluster.health-check.checkpoint-progress.window is well configure by nicolas.fraison@datadoghq.com · 4 months ago
  64. 48b18cd [FLINK-33771] Add cluster capacity awareness to autoscaler (#751) by Maximilian Michels · 4 months ago
  65. 48df9d3 [docs] Fix Typo in Standalone Autoscaler Documentation (#754) by Samrat · 4 months ago
  66. 70b2d9e [FLINK-33632] Adding custom flink mutator by AncyRominus · 4 months ago
  67. c1acd6c [hotfix] Add the feature description of flink-operator in the document (#753) by Caican Cai · 4 months ago
  68. f23d753 [hotfix] Add year 2024 to Notice files (#752) by Caican Cai · 4 months ago
  69. f67cba9 [FLINK-34021][autoscaler] Print jobKey in the Autoscaler standalone log by Rui Fan · 4 months ago
  70. f6496f5 [FLINK-30593][autoscaler] Improve restart time tracking (#735) by Alexander Fedulov · 4 months ago
  71. 66e1433 [FLINK-33535] Support autoscaler for session jobs by Gyula Fora · 6 months ago
  72. 58b8ea8 [FLINK-33993] Fix misleading events for scaling effectiveness detection (#748) by Maximilian Michels · 4 months ago
  73. 0f14043 [hotfix][docs] Add the -am when generate the docs by Rui Fan · 4 months ago
  74. 456fb6e [FLINK-33966][autoscaler] Improve the comments of getNumRecordsInPerSecond (#743) by Yang-LI-CS · 4 months ago
  75. 394e529 [hotfix][autoscaler] Fix the StandaloneAutoscalerExecutorTest.testScaling fails occasionally due to race condition (#746) by Rui Fan · 4 months ago
  76. 141aac7 [FLINK-33814][autoscaler] Autoscaler Standalone control loop supports multiple thread by Rui Fan · 4 months ago
  77. 1da4e77 [FLINK-33814][autoscaler] Update the result type of JobListFetcher from List to Collection by Rui Fan · 4 months ago
  78. 805b758 [docs] Typo: add missing word "start" (#745) by Guillaume Vauvert · 4 months ago
  79. fa93843 [FLINK-33965][autoscaler] Generate the configuration doc for autoscaler standalone by Rui Fan · 4 months ago
  80. 3cae590 [FLINK-33965][autoscaler] Introducing the AutoscalerStandaloneOptions to simplify options for autoscaler standalone by Rui Fan · 4 months ago
  81. 8e6bfe0 [FLINK-33795] Add a new config to forbid autoscale execution in the configured excluded periods (#728) by flashJd · 4 months ago
  82. fa8cf75 [FLINK-33917] Fix null hostname for certain edge cases (#738) by ensctom · 4 months ago
  83. 515f018 [docs] Add a notice for operator pod resources by Hao Xin · 6 months ago
  84. f01f8ec [FLINK-33812] Consider override parallelism when calculating the parallelism of a job by Jerry Wang · 5 months ago
  85. 808edfd [docs] Fix a few doc mistakes (#736) by Ryan van Huuksloot · 5 months ago
  86. c254544 [hotfix] Only report evaluated vertex metrics by Gyula Fora · 5 months ago
  87. f6adb400 [FLINK-33764] Track Heap usage and GC pressure to avoid unnecessary scaling by Gyula Fora · 10 months ago
  88. 80d9437 [FLINK-33770] Silence Configuration logging for INFO messages (#734) by Maximilian Michels · 5 months ago
  89. 2136c7a [FLINK-33813][autoscaler] Improve time formatting for easier reading inside the autoscaler by Rui Fan · 5 months ago
  90. 3009725 [FLINK-33454] Add IngressTls to support TLS within the managed Ingress, also add Label Passthrough by Ryan van Huuksloot · 5 months ago
  91. 9e8dcd9 [FLINK-33763] Support savepoint redeployment through a nonce by Gyula Fora · 5 months ago
  92. ef250a0 [FLINK-33770] Promote deprecated autoscaler keys to fallback keys (#725) by Maximilian Michels · 5 months ago
  93. 30566ed [Flink 31966] Flink Kubernetes operator lacks TLS support by Tony Garrard · 5 months ago
  94. 98ad5b8 Add Java client library update process to the Upgrade page (#723) by Maximilian Michels · 5 months ago
  95. e452826 [FLINK-33645] Taskmanager env vars in config not given to taskmanager by Tony Garrard · 5 months ago
  96. ca1d847 [FLINK-33710] Prevent triggering cluster upgrades for permutations of the same overrides (#721) by Maximilian Michels · 5 months ago
  97. 158cbe2 [FLINK-33710] Prevent NOOP spec updates from the autoscaler parallelism override map (#720) by Maximilian Michels · 5 months ago
  98. 51a9104 [FLINK-33522] Be ware of SerializedThrowable when checking for StopWithSavepointStoppingException (#716) by Maximilian Michels · 5 months ago
  99. 34b1239 [FLINK-33701][autoscaler] Fix the doc about restart.time-tracking.enabled by Rui Fan · 5 months ago
  100. 984fead [FLINK-30593] Add tests for ScalingTracking#removeOldRecords() (#715) by Alexander Fedulov · 5 months ago