in pkg/flink/handler.go [139:146]
func (flinkResourceHandler) BuildIdentityResource(ctx context.Context, taskCtx pluginsCore.TaskExecutionMetadata) (client.Object, error) {
return &flinkOp.FlinkCluster{
TypeMeta: metav1.TypeMeta{
Kind: KindFlinkCluster,
APIVersion: flinkOp.GroupVersion.String(),
},
}, nil
}