This is an automated email from the ASF dual-hosted git repository.
gyfora pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git
The following commit(s) were added to refs/heads/main by this push:
new d9973459 [hotfix][docs] Fix Custom Flink Resource Mutators
documentation code section (#1100)
d9973459 is described below
commit d997345919070bab216de931ffa71deb28365ed4
Author: Dennis-Mircea Ciupitu <[email protected]>
AuthorDate: Mon Apr 27 08:57:21 2026 +0300
[hotfix][docs] Fix Custom Flink Resource Mutators documentation code
section (#1100)
---
docs/content.zh/docs/operations/plugins.md | 31 ++++++++++++++----------------
docs/content/docs/operations/plugins.md | 31 ++++++++++++++----------------
2 files changed, 28 insertions(+), 34 deletions(-)
diff --git a/docs/content.zh/docs/operations/plugins.md
b/docs/content.zh/docs/operations/plugins.md
index 3abd2c3a..92356935 100644
--- a/docs/content.zh/docs/operations/plugins.md
+++ b/docs/content.zh/docs/operations/plugins.md
@@ -131,33 +131,30 @@ That folder is added to classpath upon initialization.
The following steps demonstrate how to develop and use a custom mutator.
1. Implement `FlinkResourceMutator` interface:
- ```java
- package org.apache.flink.mutator;
+ ```java
+ package org.apache.flink.mutator;
import org.apache.flink.kubernetes.operator.api.FlinkDeployment;
import org.apache.flink.kubernetes.operator.api.FlinkSessionJob;
import org.apache.flink.kubernetes.operator.mutator.FlinkResourceMutator;
-
+
import java.util.Optional;
-
+
/** Custom Flink Mutator. */
public class CustomFlinkMutator implements FlinkResourceMutator {
-
- @Override
- public FlinkDeployment mutateDeployment(FlinkDeployment deployment) {
-
+
+ @Override
+ public FlinkDeployment mutateDeployment(FlinkDeployment deployment) {
return deployment;
- }
-
- @Override
- public FlinkSessionJob mutateSessionJob(
+ }
+
+ @Override
+ public FlinkSessionJob mutateSessionJob(
FlinkSessionJob sessionJob, Optional<FlinkDeployment> session) {
-
return sessionJob;
- }
-}
-
- ```
+ }
+ }
+ ```
2. Create service definition file
`org.apache.flink.kubernetes.operator.mutator.FlinkResourceMutator` in
`META-INF/services`. With custom `FlinkResourceMutator` implementation, the
service definition describes as follows:
```text
diff --git a/docs/content/docs/operations/plugins.md
b/docs/content/docs/operations/plugins.md
index 6503f57f..4f387add 100644
--- a/docs/content/docs/operations/plugins.md
+++ b/docs/content/docs/operations/plugins.md
@@ -131,33 +131,30 @@ That folder is added to classpath upon initialization.
The following steps demonstrate how to develop and use a custom mutator.
1. Implement `FlinkResourceMutator` interface:
- ```java
- package org.apache.flink.mutator;
+ ```java
+ package org.apache.flink.mutator;
import org.apache.flink.kubernetes.operator.api.FlinkDeployment;
import org.apache.flink.kubernetes.operator.api.FlinkSessionJob;
import org.apache.flink.kubernetes.operator.mutator.FlinkResourceMutator;
-
+
import java.util.Optional;
-
+
/** Custom Flink Mutator. */
public class CustomFlinkMutator implements FlinkResourceMutator {
-
- @Override
- public FlinkDeployment mutateDeployment(FlinkDeployment deployment) {
-
+
+ @Override
+ public FlinkDeployment mutateDeployment(FlinkDeployment deployment) {
return deployment;
- }
-
- @Override
- public FlinkSessionJob mutateSessionJob(
+ }
+
+ @Override
+ public FlinkSessionJob mutateSessionJob(
FlinkSessionJob sessionJob, Optional<FlinkDeployment> session) {
-
return sessionJob;
- }
-}
-
- ```
+ }
+ }
+ ```
2. Create service definition file
`org.apache.flink.kubernetes.operator.mutator.FlinkResourceMutator` in
`META-INF/services`. With custom `FlinkResourceMutator` implementation, the
service definition describes as follows:
```text
