Skip to content

Commit d46ead7

Browse files
committed
fix from cr
Signed-off-by: Attila Mészáros <[email protected]>
1 parent 9c0c78c commit d46ead7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventSourceUtils.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ public static InformerEventSource<Deployment, FlinkDeployment> getDeploymentInfo
116116
flinkDeployment.getMetadata().getNamespace())));
117117

118118
var configuration =
119-
InformerEventSourceConfiguration.from(FlinkSessionJob.class, FlinkSessionJob.class)
119+
InformerEventSourceConfiguration.from(FlinkSessionJob.class, FlinkDeployment.class)
120120
.withSecondaryToPrimaryMapper(
121121
sessionJob ->
122122
context

0 commit comments

Comments
 (0)