path # lines of code # active days days since first update days since last update # commits # contributors first updated last updated first contributor last contributor flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/FlinkStateSnapshot.java 25 1 400 400 1 1 2024-04-03 2024-04-03 mczagany@cloudera.com mczagany@cloudera.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/diff/Diffable.java 4 1 921 921 1 1 2022-10-30 2022-10-30 marton@apple.com marton@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/diff/SpecDiff.java 27 3 921 514 3 2 2022-10-30 2023-12-11 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/diff/DiffType.java 14 2 921 514 2 2 2022-10-30 2023-12-11 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/utils/SpecWithMeta.java 9 1 921 921 1 1 2022-10-30 2022-10-30 marton@apple.com marton@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/utils/FlinkResourceUtils.java 35 1 645 645 1 1 2023-08-02 2023-08-02 1492164+afedulov@users.noreply.github.com 1492164+afedulov@users.noreply.github.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/utils/SpecUtils.java 67 2 921 258 2 2 2022-10-30 2024-08-23 marton@apple.com 65053157+angelachenn@users.noreply.github.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/FlinkSessionJobList.java 7 2 921 913 2 2 2022-10-30 2022-11-07 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/AbstractFlinkResource.java 10 1 921 921 1 1 2022-10-30 2022-10-30 marton@apple.com marton@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/reconciler/ReconciliationMetadata.java 26 2 921 258 2 2 2022-10-30 2024-08-23 marton@apple.com 65053157+angelachenn@users.noreply.github.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/UpgradeMode.java 12 1 921 921 1 1 2022-10-30 2022-10-30 marton@apple.com marton@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/CheckpointSpec.java 12 2 400 287 2 2 2024-04-03 2024-07-25 mczagany@cloudera.com czmate10@gmail.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/TaskManagerSpec.java 28 5 921 457 5 4 2022-10-30 2024-02-06 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/FlinkStateSnapshotSpec.java 26 1 400 400 1 1 2024-04-03 2024-04-03 mczagany@cloudera.com mczagany@cloudera.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/JobState.java 10 1 921 921 1 1 2022-10-30 2022-10-30 marton@apple.com marton@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/JobManagerSpec.java 22 3 921 457 3 3 2022-10-30 2024-02-06 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/JobReference.java 40 3 400 253 3 3 2024-04-03 2024-08-28 mczagany@cloudera.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/FlinkVersion.java 44 9 921 99 9 6 2022-10-30 2025-01-29 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/KubernetesDeploymentMode.java 17 1 921 921 1 1 2022-10-30 2022-10-30 marton@apple.com marton@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/FlinkSessionJobSpec.java 20 2 921 750 2 2 2022-10-30 2023-04-19 marton@apple.com darenwkt@amazon.co.uk flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/AbstractFlinkSpec.java 30 4 921 514 4 2 2022-10-30 2023-12-11 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/IngressSpec.java 23 3 921 513 3 3 2022-10-30 2023-12-12 marton@apple.com ryanvanhuuksloot@gmail.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/Resource.java 16 3 921 750 3 3 2022-10-30 2023-04-19 marton@apple.com darenwkt@amazon.co.uk flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/SavepointSpec.java 20 1 400 400 1 1 2024-04-03 2024-04-03 mczagany@cloudera.com mczagany@cloudera.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/JobSpec.java 42 8 921 119 8 5 2022-10-30 2025-01-09 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/FlinkDeploymentSpec.java 34 3 921 457 3 3 2022-10-30 2024-02-06 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/JobKind.java 9 1 400 400 1 1 2024-04-03 2024-04-03 mczagany@cloudera.com mczagany@cloudera.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/validation/CrdCompatibilityChecker.java 137 5 921 263 5 3 2022-10-30 2024-08-18 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/FlinkSessionJob.java 28 2 921 775 2 2 2022-10-30 2023-03-25 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/FlinkDeploymentReconciliationStatus.java 18 2 921 750 2 2 2022-10-30 2023-04-19 marton@apple.com darenwkt@amazon.co.uk flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/Checkpoint.java 38 1 645 645 1 1 2023-08-02 2023-08-02 1492164+afedulov@users.noreply.github.com 1492164+afedulov@users.noreply.github.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/FlinkSessionJobReconciliationStatus.java 16 2 921 750 2 2 2022-10-30 2023-04-19 marton@apple.com darenwkt@amazon.co.uk flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/Savepoint.java 46 4 921 645 4 3 2022-10-30 2023-08-02 marton@apple.com 1492164+afedulov@users.noreply.github.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/SnapshotInfo.java 13 2 645 400 2 2 2023-08-02 2024-04-03 1492164+afedulov@users.noreply.github.com mczagany@cloudera.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/JobStatus.java 25 7 921 253 7 5 2022-10-30 2024-08-28 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/CommonStatus.java 56 11 921 216 11 4 2022-10-30 2024-10-04 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/CheckpointInfo.java 68 2 645 400 2 2 2023-08-02 2024-04-03 1492164+afedulov@users.noreply.github.com mczagany@cloudera.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/SavepointInfo.java 81 6 921 216 6 4 2022-10-30 2024-10-04 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/SnapshotTriggerType.java 7 1 645 645 1 1 2023-08-02 2023-08-02 1492164+afedulov@users.noreply.github.com 1492164+afedulov@users.noreply.github.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/SavepointFormatType.java 8 2 921 400 2 2 2022-10-30 2024-04-03 marton@apple.com mczagany@cloudera.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/ReconciliationStatus.java 58 6 921 216 6 4 2022-10-30 2024-10-04 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/CheckpointType.java 20 1 645 645 1 1 2023-08-02 2023-08-02 1492164+afedulov@users.noreply.github.com 1492164+afedulov@users.noreply.github.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/JobManagerDeploymentStatus.java 8 1 921 921 1 1 2022-10-30 2022-10-30 marton@apple.com marton@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/FlinkSessionJobStatus.java 22 2 921 750 2 2 2022-10-30 2023-04-19 marton@apple.com darenwkt@amazon.co.uk flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/ReconciliationState.java 7 1 921 921 1 1 2022-10-30 2022-10-30 marton@apple.com marton@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/TaskManagerInfo.java 19 2 921 750 2 2 2022-10-30 2023-04-19 marton@apple.com darenwkt@amazon.co.uk flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/Snapshot.java 5 1 645 645 1 1 2023-08-02 2023-08-02 1492164+afedulov@users.noreply.github.com 1492164+afedulov@users.noreply.github.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/FlinkStateSnapshotStatus.java 35 1 400 400 1 1 2024-04-03 2024-04-03 mczagany@cloudera.com mczagany@cloudera.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/FlinkDeploymentStatus.java 28 2 921 750 2 2 2022-10-30 2023-04-19 marton@apple.com darenwkt@amazon.co.uk flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/listener/FlinkResourceListener.java 59 2 917 400 2 2 2022-11-03 2024-04-03 marton@apple.com mczagany@cloudera.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/CrdConstants.java 15 4 921 217 4 4 2022-10-30 2024-10-03 marton@apple.com czmate10@gmail.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/FlinkDeployment.java 30 2 921 775 2 2 2022-10-30 2023-03-25 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/lifecycle/ResourceLifecycleState.java 43 3 918 244 3 3 2022-11-02 2024-09-06 marton@apple.com g_fora@apple.com flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/FlinkDeploymentList.java 7 2 921 913 2 2 2022-10-30 2022-11-07 marton@apple.com g_fora@apple.com tools/olm/csv-template/bases/initContainer.yaml 16 1 890 890 1 1 2022-11-30 2022-11-30 htchang@us.ibm.com htchang@us.ibm.com tools/maven/suppressions.xml 6 1 1192 1192 1 1 2022-02-01 2022-02-01 g_fora@apple.com g_fora@apple.com tools/releasing/apache_header.yaml 1 1 1135 1135 1 1 2022-03-30 2022-03-30 g_fora@apple.com g_fora@apple.com flink-autoscaler/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/AggregatedMetric.java 97 1 259 259 1 1 2024-08-22 2024-08-22 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java 337 2 384 314 2 2 2024-04-19 2024-06-28 gabor_somogyi2@apple.com ferenc.csaky@pm.me flink-autoscaler/src/main/java/org/apache/flink/runtime/rest/messages/json/SlotSharingGroupIDSerializer.java 17 1 384 384 1 1 2024-04-19 2024-04-19 gabor_somogyi2@apple.com gabor_somogyi2@apple.com flink-autoscaler/src/main/java/org/apache/flink/runtime/rest/messages/json/SlotSharingGroupIDDeserializer.java 18 1 384 384 1 1 2024-04-19 2024-04-19 gabor_somogyi2@apple.com gabor_somogyi2@apple.com flink-autoscaler/src/main/java/org/apache/flink/runtime/rest/messages/json/SlotSharingGroupIdConverter.java 18 1 384 384 1 1 2024-04-19 2024-04-19 gabor_somogyi2@apple.com gabor_somogyi2@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/Edge.java 12 1 597 597 1 1 2023-09-19 2023-09-19 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/ScalingMetrics.java 205 9 657 259 9 4 2023-07-21 2024-08-22 g_fora@apple.com 1996fanrui@gmail.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/EvaluatedScalingMetric.java 19 2 597 448 2 2 2023-09-19 2024-02-15 1996fanrui@gmail.com mxm@apache.org flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/ScalingHistoryUtils.java 100 3 593 531 4 3 2023-09-23 2023-11-24 1996fanrui@gmail.com 1492164+afedulov@users.noreply.github.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/CollectedMetricHistory.java 13 2 597 472 2 1 2023-09-19 2024-01-22 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/FlinkMetric.java 46 7 657 259 7 3 2023-07-21 2024-08-22 g_fora@apple.com 1996fanrui@gmail.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/AutoscalerFlinkMetrics.java 105 2 593 513 2 2 2023-09-23 2023-12-12 1996fanrui@gmail.com g_fora@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/MetricAggregator.java 19 1 597 597 1 1 2023-09-19 2023-09-19 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/CollectedMetrics.java 13 3 657 443 3 2 2023-07-21 2024-02-20 g_fora@apple.com g_fora@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/ScalingMetric.java 45 9 657 209 9 4 2023-07-21 2024-10-11 g_fora@apple.com 731030576@qq.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/MetricNotFoundException.java 7 1 553 553 1 1 2023-11-02 2023-11-02 mxm@apache.org mxm@apache.org flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/EvaluatedMetrics.java 13 1 657 657 1 1 2023-07-21 2023-07-21 g_fora@apple.com g_fora@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java 444 15 657 77 15 7 2023-07-21 2025-02-20 g_fora@apple.com matyas_orhidi@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/RestApiMetricsCollector.java 184 6 657 259 6 3 2023-07-21 2024-08-22 g_fora@apple.com 1996fanrui@gmail.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerContext.java 38 4 598 448 4 3 2023-09-18 2024-02-15 1996fanrui@gmail.com mxm@apache.org flink-autoscaler/src/main/java/org/apache/flink/autoscaler/state/InMemoryAutoScalerStateStore.java 142 10 593 102 10 5 2023-09-23 2025-01-26 1996fanrui@gmail.com dsaisharath@uber.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/state/AutoScalerStateStore.java 46 10 598 102 10 5 2023-09-18 2025-01-26 1996fanrui@gmail.com dsaisharath@uber.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/realizer/ScalingRealizer.java 11 5 598 282 5 4 2023-09-18 2024-07-30 1996fanrui@gmail.com 731030576@qq.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/DelayedScaleDown.java 103 3 244 153 3 2 2024-09-06 2024-12-06 1996fanrui@gmail.com fanrui@apache.org flink-autoscaler/src/main/java/org/apache/flink/autoscaler/topology/ShipStrategy.java 22 1 437 437 1 1 2024-02-26 2024-02-26 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/topology/JobTopology.java 138 8 597 119 8 4 2023-09-19 2025-01-09 1996fanrui@gmail.com dsaisharath@uber.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/topology/VertexInfo.java 64 6 597 209 6 4 2023-09-19 2024-10-11 1996fanrui@gmail.com 731030576@qq.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/topology/IOMetrics.java 16 1 443 443 1 1 2024-02-20 2024-02-20 g_fora@apple.com g_fora@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/DateTimeUtils.java 23 3 512 261 3 3 2023-12-13 2024-08-20 1996fanrui@gmail.com 4469996+mateczagany@users.noreply.github.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/AutoScalerUtils.java 108 4 597 2 4 3 2023-09-19 2025-05-06 1996fanrui@gmail.com pchoudhury22@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/ResourceCheckUtils.java 45 2 456 440 2 1 2024-02-07 2024-02-23 mxm@apache.org mxm@apache.org flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/CalendarUtils.java 104 1 492 492 1 1 2024-01-02 2024-01-02 jianyonghua@163.com jianyonghua@163.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/AutoScalerSerDeModule.java 45 2 597 471 2 1 2023-09-19 2024-01-23 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/JobStatusUtils.java 39 2 412 350 2 2 2024-03-22 2024-05-23 1996fanrui@gmail.com g_fora@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingSummary.java 30 2 597 471 2 1 2023-09-19 2024-01-23 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java 385 19 657 143 20 8 2023-07-21 2024-12-16 g_fora@apple.com fanrui@apache.org flink-autoscaler/src/main/java/org/apache/flink/autoscaler/exceptions/NotReadyException.java 9 2 553 119 2 2 2023-11-02 2025-01-09 mxm@apache.org dsaisharath@uber.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/resources/NoopResourceCheck.java 9 1 476 476 1 1 2024-01-18 2024-01-18 mxm@apache.org mxm@apache.org flink-autoscaler/src/main/java/org/apache/flink/autoscaler/resources/ResourceCheck.java 9 1 476 476 1 1 2024-01-18 2024-01-18 mxm@apache.org mxm@apache.org flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java 354 19 657 2 20 9 2023-07-21 2025-05-06 g_fora@apple.com pchoudhury22@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryTuning.java 284 6 448 339 7 3 2024-02-15 2024-06-03 mxm@apache.org nicolas.fraison@datadoghq.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryBudget.java 18 1 441 441 1 1 2024-02-22 2024-02-22 mxm@apache.org mxm@apache.org flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/ConfigChanges.java 37 2 441 427 2 1 2024-02-22 2024-03-07 mxm@apache.org mxm@apache.org flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryScaling.java 61 1 427 427 1 1 2024-03-07 2024-03-07 mxm@apache.org mxm@apache.org flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingRecord.java 11 2 531 484 2 1 2023-11-24 2024-01-10 1492164+afedulov@users.noreply.github.com 1492164+afedulov@users.noreply.github.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/VertexScalingReport.java 17 1 477 477 1 1 2024-01-17 2024-01-17 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoScalerEventHandler.java 89 8 598 102 9 6 2023-09-18 2025-01-26 1996fanrui@gmail.com dsaisharath@uber.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoscalerEventUtils.java 52 2 477 462 2 1 2024-01-17 2024-02-01 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/LoggingEventHandler.java 29 2 548 102 2 2 2023-11-07 2025-01-26 1996fanrui@gmail.com dsaisharath@uber.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobVertexScaler.java 450 14 593 2 14 9 2023-09-23 2025-05-06 1996fanrui@gmail.com pchoudhury22@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java 136 5 531 443 5 3 2023-11-24 2024-02-20 1492164+afedulov@users.noreply.github.com g_fora@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScaler.java 7 3 598 118 3 2 2023-09-18 2025-01-10 1996fanrui@gmail.com g_fora@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/NoopJobAutoscaler.java 8 2 593 118 2 2 2023-09-23 2025-01-10 1996fanrui@gmail.com g_fora@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java 194 18 657 118 19 5 2023-07-21 2025-01-10 g_fora@apple.com g_fora@apple.com flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java 425 15 657 114 15 5 2023-07-21 2025-01-14 g_fora@apple.com 731030576@qq.com flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/state/JdbcStateStore.java 63 2 510 102 2 2 2023-12-15 2025-01-26 1996fanrui@gmail.com dsaisharath@uber.com flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/state/JobStateView.java 189 1 510 510 1 1 2023-12-15 2023-12-15 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/state/StateType.java 30 3 510 244 3 2 2023-12-15 2024-09-06 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/state/JdbcAutoScalerStateStore.java 272 8 510 102 8 5 2023-12-15 2025-01-26 1996fanrui@gmail.com dsaisharath@uber.com flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/state/JdbcStateInteractor.java 104 3 510 102 3 2 2023-12-15 2025-01-26 1996fanrui@gmail.com dsaisharath@uber.com flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/AutoScalerEvent.java 15 1 463 463 1 1 2024-01-31 2024-01-31 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcEventInteractor.java 149 3 463 102 3 3 2024-01-31 2025-01-26 1996fanrui@gmail.com dsaisharath@uber.com flink-autoscaler-plugin-jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcAutoScalerEventHandler.java 137 4 463 102 4 3 2024-01-31 2025-01-26 1996fanrui@gmail.com dsaisharath@uber.com flink-autoscaler-plugin-jdbc/src/main/resources/schema/postgres_schema.sql 26 3 510 457 3 1 2023-12-15 2024-02-06 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler-plugin-jdbc/src/main/resources/schema/derby_schema.sql 25 3 510 457 3 1 2023-12-15 2024-02-06 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler-plugin-jdbc/src/main/resources/schema/mysql_schema.sql 27 3 510 457 3 1 2023-12-15 2024-02-06 1996fanrui@gmail.com 1996fanrui@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/AggregatedMetric.java 97 1 259 259 1 1 2024-08-22 2024-08-22 1996fanrui@gmail.com 1996fanrui@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/IOMetricsInfo.java 133 2 889 435 2 1 2022-12-01 2024-02-28 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/KubernetesResourceMetricGroup.java 30 1 1036 1036 1 1 2022-07-07 2022-07-07 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/KubernetesResourceNamespaceScopeFormat.java 27 5 1036 664 5 3 2022-07-07 2023-07-14 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/FlinkStateSnapshotMetrics.java 120 2 400 225 2 2 2024-04-03 2024-09-25 mczagany@cloudera.com czmate10@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/KubernetesResourceScopeFormat.java 32 5 1036 664 5 3 2022-07-07 2023-07-14 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/KubernetesOperatorScopeFormat.java 20 4 1179 664 4 4 2022-02-14 2023-07-14 matyas_orhidi@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/KubernetesClientMetrics.java 222 6 1034 185 6 5 2022-07-09 2024-11-04 matyas_orhidi@apple.com 53612764+morhidi@users.noreply.github.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/FlinkSessionJobMetrics.java 41 4 1101 921 4 3 2022-05-03 2022-10-30 matyas_orhidi@apple.com marton@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/FlinkDeploymentMetrics.java 217 10 1101 90 10 6 2022-05-03 2025-02-07 matyas_orhidi@apple.com mxm@apache.org flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/OperatorMetricUtils.java 167 15 1179 859 16 5 2022-02-14 2022-12-31 matyas_orhidi@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/KubernetesOperatorMetricGroup.java 66 7 1179 400 7 5 2022-02-14 2024-04-03 matyas_orhidi@apple.com mczagany@cloudera.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/OperatorJosdkMetrics.java 181 11 1036 387 11 4 2022-07-07 2024-04-16 g_fora@apple.com marton@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/MetricManager.java 80 10 1101 400 10 5 2022-05-03 2024-04-03 matyas_orhidi@apple.com mczagany@cloudera.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/lifecycle/LifecycleMetrics.java 231 11 1030 641 11 5 2022-07-13 2023-08-06 g_fora@apple.com programgeek@163.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/lifecycle/ResourceLifecycleMetricTracker.java 105 4 1030 918 4 3 2022-07-13 2022-11-02 g_fora@apple.com marton@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/KubernetesResourceNamespaceMetricGroup.java 50 3 1036 859 3 1 2022-07-07 2022-12-31 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/CustomResourceMetrics.java 6 2 1101 1020 2 1 2022-05-03 2022-07-23 matyas_orhidi@apple.com matyas_orhidi@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/KubernetesOperatorMetricOptions.java 83 14 1179 185 15 6 2022-02-14 2024-11-04 matyas_orhidi@apple.com 53612764+morhidi@users.noreply.github.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/ssl/ReloadableSslContext.java 74 1 969 969 1 1 2022-09-12 2022-09-12 gabor_somogyi2@apple.com gabor_somogyi2@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/mutator/DefaultFlinkMutator.java 37 2 479 400 2 2 2024-01-15 2024-04-03 ancy.rominus@ibm.com mczagany@cloudera.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/mutator/FlinkResourceMutator.java 11 3 479 42 3 3 2024-01-15 2025-03-27 ancy.rominus@ibm.com rmenesespinillos@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/FlinkOperator.java 236 72 1183 225 78 18 2022-02-10 2024-09-25 g_fora@apple.com czmate10@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/SnapshotStatus.java 6 1 645 645 1 1 2023-08-02 2023-08-02 1492164+afedulov@users.noreply.github.com 1492164+afedulov@users.noreply.github.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/MutatorUtils.java 35 1 479 479 1 1 2024-01-15 2024-01-15 ancy.rominus@ibm.com ancy.rominus@ibm.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkStateSnapshotUtils.java 258 8 400 217 8 4 2024-04-03 2024-10-03 mczagany@cloudera.com czmate10@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventRecorder.java 249 25 1085 41 25 12 2022-05-19 2025-03-28 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/ExceptionUtils.java 59 3 73 41 3 2 2025-02-24 2025-03-28 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java 358 45 1183 42 47 16 2022-02-10 2025-03-27 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/StatusRecorder.java 243 21 1085 42 21 10 2022-05-19 2025-03-27 g_fora@apple.com rmenesespinillos@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventSourceUtils.java 248 11 1081 217 11 8 2022-05-23 2024-10-03 matyas_orhidi@apple.com czmate10@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/IngressUtils.java 237 7 1183 513 7 5 2022-02-10 2023-12-12 matyas_orhidi@apple.com ryanvanhuuksloot@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/ConfigOptionUtils.java 21 2 1063 1039 2 2 2022-06-10 2022-07-04 programgeek@163.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkResourceExceptionUtils.java 161 5 925 400 5 4 2022-10-26 2024-04-03 darenwkt@amazon.co.uk mczagany@cloudera.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/SnapshotUtils.java 286 11 645 42 11 8 2023-08-02 2025-03-27 1492164+afedulov@users.noreply.github.com rmenesespinillos@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/ValidatorUtils.java 52 4 1128 558 4 2 2022-04-06 2023-10-28 programgeek@163.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventUtils.java 254 14 1087 41 15 7 2022-05-17 2025-03-28 matyas_orhidi@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/KubernetesClientUtils.java 43 9 1034 259 9 6 2022-07-09 2024-08-22 matyas_orhidi@apple.com sam@quadrocket.co.uk flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EnvUtils.java 146 8 1170 518 8 6 2022-02-23 2023-12-07 yuli.mwj@alibaba-inc.com garrard@uk.ibm.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/fs/FileSystemWatchService.java 64 1 969 969 1 1 2022-09-12 2022-09-12 gabor_somogyi2@apple.com gabor_somogyi2@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/KubernetesJobAutoScalerContext.java 46 4 593 448 4 2 2023-09-23 2024-02-15 1996fanrui@gmail.com mxm@apache.org flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/state/ConfigMapView.java 79 1 540 540 1 1 2023-11-15 2023-11-15 mxm@apache.org mxm@apache.org flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/state/KubernetesAutoScalerStateStore.java 332 11 657 102 11 7 2023-07-21 2025-01-26 g_fora@apple.com dsaisharath@uber.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/state/ConfigMapStore.java 94 2 540 97 2 2 2023-11-15 2025-01-31 mxm@apache.org g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/AutoscalerFactory.java 28 4 593 476 4 3 2023-09-23 2024-01-18 1996fanrui@gmail.com mxm@apache.org flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/KubernetesScalingRealizer.java 71 5 593 441 5 2 2023-09-23 2024-02-22 1996fanrui@gmail.com mxm@apache.org flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/KubernetesAutoScalerEventHandler.java 79 5 593 102 5 4 2023-09-23 2025-01-26 1996fanrui@gmail.com dsaisharath@uber.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SavepointFetchResult.java 17 4 1164 1078 4 3 2022-03-01 2022-05-26 matyas_orhidi@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/CheckpointFetchResult.java 17 2 645 400 2 2 2023-08-02 2024-04-03 1492164+afedulov@users.noreply.github.com mczagany@cloudera.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/AbstractFlinkResourceObserver.java 54 10 939 42 10 5 2022-10-12 2025-03-27 g_fora@apple.com rmenesespinillos@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserver.java 156 32 1183 41 32 9 2022-02-10 2025-03-28 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/ClusterHealthObserver.java 67 5 955 720 5 3 2022-09-26 2023-05-19 gabor_somogyi2@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/snapshot/StateSnapshotObserver.java 128 2 400 287 2 2 2024-04-03 2024-07-25 mczagany@cloudera.com czmate10@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/Observer.java 6 9 1165 859 10 5 2022-02-28 2022-12-31 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/SnapshotObserver.java 360 9 645 72 9 6 2023-08-02 2025-02-25 1492164+afedulov@users.noreply.github.com luca.castelli@shopify.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/FlinkDeploymentObserverFactory.java 35 4 939 671 4 2 2022-10-12 2023-07-07 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/ApplicationObserver.java 42 24 1131 350 24 8 2022-04-03 2024-05-23 yuli.mwj@alibaba-inc.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/SessionObserver.java 27 15 1131 90 15 4 2022-04-03 2025-02-07 yuli.mwj@alibaba-inc.com mxm@apache.org flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractFlinkDeploymentObserver.java 225 17 939 41 17 8 2022-10-12 2025-03-28 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/CheckpointStatsResult.java 17 1 400 400 1 1 2024-04-03 2024-04-03 mczagany@cloudera.com mczagany@cloudera.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/sessionjob/FlinkSessionJobObserver.java 62 13 939 216 13 6 2022-10-12 2024-10-04 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/ClusterHealthEvaluator.java 200 4 955 367 4 3 2022-09-26 2024-05-06 gabor_somogyi2@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/resources/KubernetesResource.java 38 1 476 476 1 1 2024-01-18 2024-01-18 mxm@apache.org mxm@apache.org flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/resources/KubernetesNodeResourceInfo.java 48 1 476 476 1 1 2024-01-18 2024-01-18 mxm@apache.org mxm@apache.org flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/resources/ClusterResourceManager.java 192 1 476 476 1 1 2024-01-18 2024-01-18 mxm@apache.org mxm@apache.org flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/resources/ClusterResourceView.java 41 1 476 476 1 1 2024-01-18 2024-01-18 mxm@apache.org mxm@apache.org flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/ReflectiveDiffBuilder.java 153 8 1015 457 8 5 2022-07-28 2024-02-06 matyas_orhidi@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/DiffResult.java 100 5 1015 514 5 4 2022-07-28 2023-12-11 matyas_orhidi@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/DiffBuilder.java 114 6 1015 665 6 4 2022-07-28 2023-07-13 matyas_orhidi@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/Diff.java 14 3 1015 921 3 2 2022-07-28 2022-10-30 matyas_orhidi@apple.com marton@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java 394 61 1164 119 63 15 2022-03-01 2025-01-09 matyas_orhidi@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/Reconciler.java 8 8 1159 859 8 3 2022-03-06 2022-12-31 yuli.mwj@alibaba-inc.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/snapshot/StateSnapshotReconciler.java 181 2 400 287 2 2 2024-04-03 2024-07-25 mczagany@cloudera.com czmate10@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java 311 62 1131 48 68 19 2022-04-03 2025-03-21 yuli.mwj@alibaba-inc.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ReconcilerFactory.java 48 18 1131 543 18 9 2022-04-03 2023-11-12 yuli.mwj@alibaba-inc.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractJobReconciler.java 520 40 1056 48 41 17 2022-06-17 2025-03-21 usamj@amazon.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/SessionReconciler.java 118 39 1131 436 40 15 2022-04-03 2024-02-27 yuli.mwj@alibaba-inc.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java 356 50 1056 118 55 19 2022-06-17 2025-01-10 usamj@amazon.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/SnapshotType.java 5 1 645 645 1 1 2023-08-02 2023-08-02 1492164+afedulov@users.noreply.github.com 1492164+afedulov@users.noreply.github.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobReconciler.java 147 28 1056 48 28 14 2022-06-17 2025-03-21 usamj@amazon.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/SnapshotTriggerTimestampStore.java 92 3 258 42 3 3 2024-08-23 2025-03-27 4469996+mateczagany@users.noreply.github.com rmenesespinillos@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkOperatorConfiguration.java 230 39 1164 185 41 18 2022-03-01 2024-11-04 matyas_orhidi@apple.com 53612764+morhidi@users.noreply.github.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java 487 33 1108 97 35 16 2022-04-26 2025-01-31 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java 558 55 1118 161 55 22 2022-04-16 2024-11-28 yuli.mwj@alibaba-inc.com code@tomcooper.dev flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/Mode.java 17 5 1152 921 5 4 2022-03-13 2022-10-30 yuli.mwj@alibaba-inc.com marton@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigManager.java 329 24 1108 42 24 10 2022-04-26 2025-03-27 g_fora@apple.com rmenesespinillos@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/CheckpointHistoryWrapper.java 97 4 1096 720 4 2 2022-05-08 2023-05-19 g_fora@apple.com tamirsagi@users.noreply.github.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java 1030 53 1056 42 55 23 2022-06-17 2025-03-27 usamj@amazon.com rmenesespinillos@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java 163 23 1056 99 23 12 2022-06-17 2025-01-29 usamj@amazon.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkService.java 95 58 1183 90 66 18 2022-02-10 2025-02-07 g_fora@apple.com mxm@apache.org flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/CustomDashboardConfigurationHeaders.java 44 2 1091 828 2 2 2022-05-13 2023-01-31 matyas_orhidi@apple.com rmeneses@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/NativeFlinkService.java 266 28 1056 216 28 12 2022-06-17 2024-10-04 usamj@amazon.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/CustomDashboardConfiguration.java 17 1 1091 1091 1 1 2022-05-13 2022-05-13 matyas_orhidi@apple.com matyas_orhidi@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/CustomCheckpointingStatisticsHeaders.java 44 2 1096 828 2 2 2022-05-08 2023-01-31 g_fora@apple.com rmeneses@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/FlinkResourceContextFactory.java 117 9 859 217 9 5 2022-12-31 2024-10-03 g_fora@apple.com czmate10@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/SuspendMode.java 16 1 216 216 1 1 2024-10-04 2024-10-04 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/validation/DefaultValidator.java 554 45 1131 2 48 22 2022-04-03 2025-05-06 yuli.mwj@alibaba-inc.com pchoudhury22@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/validation/FlinkResourceValidator.java 14 5 1131 42 5 5 2022-04-03 2025-03-27 yuli.mwj@alibaba-inc.com rmenesespinillos@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/exception/ReconciliationException.java 13 2 1172 1150 2 2 2022-02-21 2022-03-15 matyas_orhidi@apple.com yuli.mwj@alibaba-inc.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/exception/StatusConflictException.java 7 1 910 910 1 1 2022-11-10 2022-11-10 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/exception/DeploymentFailedException.java 47 8 1157 41 8 5 2022-03-08 2025-03-28 thw@apache.org g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/exception/FlinkResourceException.java 18 1 925 925 1 1 2022-10-26 2022-10-26 darenwkt@amazon.co.uk darenwkt@amazon.co.uk flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/exception/MissingJobManagerException.java 12 1 925 925 1 1 2022-10-26 2022-10-26 darenwkt@amazon.co.uk darenwkt@amazon.co.uk flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/exception/UpgradeFailureException.java 15 1 216 216 1 1 2024-10-04 2024-10-04 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/exception/ValidationException.java 12 1 925 925 1 1 2022-10-26 2022-10-26 darenwkt@amazon.co.uk darenwkt@amazon.co.uk flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/artifact/ArtifactFetcher.java 6 3 1118 1039 3 3 2022-04-16 2022-07-04 yuli.mwj@alibaba-inc.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/artifact/ArtifactManager.java 51 6 1118 921 6 4 2022-04-16 2022-10-30 yuli.mwj@alibaba-inc.com marton@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/artifact/HttpArtifactFetcher.java 39 3 1118 821 3 3 2022-04-16 2023-02-07 yuli.mwj@alibaba-inc.com 46821078+fabiowanner@users.noreply.github.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/artifact/FileSystemBasedArtifactFetcher.java 30 2 1118 1089 2 2 2022-04-16 2022-05-15 yuli.mwj@alibaba-inc.com 30902086+fuyaoli2017@users.noreply.github.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/health/ClusterHealthInfo.java 46 2 955 835 2 1 2022-09-26 2023-01-24 gabor_somogyi2@apple.com gabor_somogyi2@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/health/HealthProbe.java 62 4 994 775 4 1 2022-08-18 2023-03-25 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/health/OperatorHealthHandler.java 43 2 994 918 2 1 2022-08-18 2022-11-02 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/health/CanaryResourceManager.java 121 2 775 612 2 2 2023-03-25 2023-09-04 g_fora@apple.com darenwkt@amazon.co.uk flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/health/InformerHealthSummary.java 36 1 812 812 1 1 2023-02-16 2023-02-16 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/health/InformerIdentifier.java 8 1 812 812 1 1 2023-02-16 2023-02-16 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/health/OperatorHealthService.java 41 1 994 994 1 1 2022-08-18 2022-08-18 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/health/HttpBootstrap.java 53 1 994 994 1 1 2022-08-18 2022-08-18 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkStateSnapshotContext.java 68 2 400 217 2 2 2024-04-03 2024-10-03 mczagany@cloudera.com czmate10@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkSessionJobContext.java 62 5 859 216 5 1 2022-12-31 2024-10-04 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentController.java 190 58 1183 41 66 13 2022-02-10 2025-03-28 matyas_orhidi@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentContext.java 39 4 859 664 4 1 2022-12-31 2023-07-14 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkStateSnapshotController.java 183 3 400 217 3 2 2024-04-03 2024-10-03 mczagany@cloudera.com czmate10@gmail.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkResourceContext.java 87 10 859 263 10 5 2022-12-31 2024-08-18 g_fora@apple.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkSessionJobController.java 178 31 1131 41 33 9 2022-04-03 2025-03-28 yuli.mwj@alibaba-inc.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/listener/ListenerUtils.java 98 4 1085 917 4 3 2022-05-19 2022-11-03 g_fora@apple.com marton@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/listener/AuditUtils.java 58 8 974 216 8 5 2022-09-07 2024-10-04 53612764+morhidi@users.noreply.github.com g_fora@apple.com flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/kubeclient/decorators/FlinkConfMountDecorator.java 178 2 97 70 2 1 2025-01-31 2025-02-27 g_fora@apple.com g_fora@apple.com flink-autoscaler-standalone/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/AggregatedMetric.java 97 1 259 259 1 1 2024-08-22 2024-08-22 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler-standalone/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/IOMetricsInfo.java 133 1 421 421 1 1 2024-03-13 2024-03-13 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/AutoscalerEventHandlerFactory.java 52 4 463 102 4 4 2024-01-31 2025-01-26 1996fanrui@gmail.com dsaisharath@uber.com flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/realizer/RescaleApiScalingRealizer.java 117 4 548 282 4 3 2023-11-07 2024-07-30 1996fanrui@gmail.com 731030576@qq.com flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/utils/HikariJDBCUtil.java 27 2 357 102 2 2 2024-05-16 2025-01-26 jam.gzczy@gmail.com dsaisharath@uber.com flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/config/AutoscalerStandaloneOptions.java 98 4 496 255 5 2 2023-12-29 2024-08-26 1996fanrui@gmail.com flinker@126.com flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/flinkcluster/FlinkClusterJobListFetcher.java 87 7 548 388 7 2 2023-11-07 2024-04-15 1996fanrui@gmail.com 1996fanrui@gmail.com flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/AutoscalerStateStoreFactory.java 53 4 496 102 4 3 2023-12-29 2025-01-26 1996fanrui@gmail.com dsaisharath@uber.com flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/StandaloneAutoscalerEntrypoint.java 72 5 548 293 6 2 2023-11-07 2024-07-19 1996fanrui@gmail.com 731030576@qq.com flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/StandaloneAutoscalerExecutor.java 144 11 555 102 11 4 2023-10-31 2025-01-26 1996fanrui@gmail.com dsaisharath@uber.com flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/JobListFetcher.java 9 3 548 388 3 1 2023-11-07 2024-04-15 1996fanrui@gmail.com 1996fanrui@gmail.com flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/standalone/StandaloneKubernetesConfigOptionsInternal.java 21 1 1108 1108 1 1 2022-04-26 2022-04-26 usamj@amazon.com usamj@amazon.com flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/standalone/KubernetesStandaloneClusterDescriptor.java 207 5 1060 99 5 3 2022-06-13 2025-01-29 usamj@amazon.com g_fora@apple.com flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/utils/StandaloneKubernetesUtils.java 31 2 1108 1009 2 2 2022-04-26 2022-08-03 usamj@amazon.com g_fora@apple.com flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/StandaloneKubernetesJobManagerParameters.java 79 7 1108 821 8 5 2022-04-26 2023-02-07 usamj@amazon.com anton.ippolitov@datadoghq.com flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/parameters/StandaloneKubernetesTaskManagerParameters.java 107 3 1108 518 3 3 2022-04-26 2023-12-07 usamj@amazon.com garrard@uk.ibm.com flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/InitStandaloneTaskManagerDecorator.java 102 2 1108 703 2 2 2022-04-26 2023-06-05 usamj@amazon.com g_fora@apple.com flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneJobManagerDecorator.java 74 8 1108 703 8 6 2022-04-26 2023-06-05 usamj@amazon.com g_fora@apple.com flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/CmdStandaloneTaskManagerDecorator.java 24 2 1108 703 2 2 2022-04-26 2023-06-05 usamj@amazon.com g_fora@apple.com flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/decorators/UserLibMountDecorator.java 63 4 1108 703 4 3 2022-04-26 2023-06-05 usamj@amazon.com g_fora@apple.com flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/FlinkStandaloneKubeClient.java 6 2 1060 703 2 2 2022-06-13 2023-06-05 usamj@amazon.com g_fora@apple.com flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/factory/StandaloneKubernetesJobManagerFactory.java 93 2 1060 703 2 2 2022-06-13 2023-06-05 usamj@amazon.com g_fora@apple.com flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/factory/StandaloneKubernetesTaskManagerFactory.java 70 3 1060 703 3 3 2022-06-13 2023-06-05 usamj@amazon.com g_fora@apple.com flink-kubernetes-standalone/src/main/java/org/apache/flink/kubernetes/operator/kubeclient/Fabric8FlinkStandaloneKubeClient.java 50 5 1060 99 5 3 2022-06-13 2025-01-29 usamj@amazon.com g_fora@apple.com helm/flink-kubernetes-operator/templates/serviceaccount.yaml 52 3 1135 980 3 3 2022-03-30 2022-09-01 marton@apple.com 124390+robsonpeixoto@users.noreply.github.com helm/flink-kubernetes-operator/templates/flink-operator.yaml 311 38 1135 10 39 23 2022-03-30 2025-04-28 marton@apple.com 107141897+ctrlaltdilj@users.noreply.github.com helm/flink-kubernetes-operator/templates/webhook.yaml 140 9 1135 92 9 7 2022-03-30 2025-02-05 marton@apple.com ttdao.2015@accountancy.smu.edu.sg helm/flink-kubernetes-operator/templates/_helpers.tpl 180 6 1135 884 6 2 2022-03-30 2022-12-06 marton@apple.com marton@apple.com helm/flink-kubernetes-operator/templates/rbac.yaml 331 13 1135 87 13 9 2022-03-30 2025-02-10 marton@apple.com timsn@users.noreply.github.com helm/flink-kubernetes-operator/values.yaml 106 33 1135 15 34 22 2022-03-30 2025-04-23 marton@apple.com thw@apache.org helm/flink-kubernetes-operator/Chart.yaml 8 14 1135 76 14 4 2022-03-30 2025-02-21 marton@apple.com g_fora@apple.com flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/FlinkValidator.java 104 12 1169 286 12 7 2022-02-24 2024-07-26 g_fora@apple.com czmate10@gmail.com flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/mutator/DefaultRequestMutator.java 59 4 1059 701 4 2 2022-06-14 2023-06-07 yuli.mwj@alibaba-inc.com g_fora@apple.com flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/mutator/FlinkMutator.java 82 5 1059 400 5 5 2022-06-14 2024-04-03 yuli.mwj@alibaba-inc.com mczagany@cloudera.com flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/AdmissionHandler.java 120 8 1183 701 8 4 2022-02-10 2023-06-07 g_fora@apple.com g_fora@apple.com flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/FlinkOperatorWebhook.java 135 19 1183 400 19 8 2022-02-10 2024-04-03 g_fora@apple.com mczagany@cloudera.com flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/informer/InformerManager.java 135 4 1054 400 4 4 2022-06-19 2024-04-03 53612764+morhidi@users.noreply.github.com mczagany@cloudera.com