From 34c6b598ccea868c0f9d53d2047eefa3145b9ef7 Mon Sep 17 00:00:00 2001
From: In-Ho Yi <iyi@snapchat.com>
Date: Wed, 30 Mar 2022 22:10:45 -0400
Subject: [PATCH] Update beam example cluster yaml

Add required spec.flinkVersion
Remove resources so that default values will be used
---
 examples/beam/with_job_server/beam_flink_cluster.yaml    | 8 +-------
 examples/beam/without_job_server/beam_flink_cluster.yaml | 8 +-------
 2 files changed, 2 insertions(+), 14 deletions(-)

diff --git a/examples/beam/with_job_server/beam_flink_cluster.yaml b/examples/beam/with_job_server/beam_flink_cluster.yaml
index 4f8d16566..dc7832d3f 100644
--- a/examples/beam/with_job_server/beam_flink_cluster.yaml
+++ b/examples/beam/with_job_server/beam_flink_cluster.yaml
@@ -3,17 +3,11 @@ kind: FlinkCluster
 metadata:
   name: beam-flink-cluster
 spec:
+  flinkVersion: 1.10.1
   image:
     name: flink:1.8.1
-  jobManager:
-    resources:
-      limits:
-        memory: "1Gi"
   taskManager:
     replicas: 2
-    resources:
-      limits:
-        memory: "2Gi"
     sidecars:
       - name: beam-worker-pool
         image: apachebeam/python3.7_sdk:2.18.0
diff --git a/examples/beam/without_job_server/beam_flink_cluster.yaml b/examples/beam/without_job_server/beam_flink_cluster.yaml
index 41481e381..5983eeb59 100644
--- a/examples/beam/without_job_server/beam_flink_cluster.yaml
+++ b/examples/beam/without_job_server/beam_flink_cluster.yaml
@@ -3,17 +3,11 @@ kind: FlinkCluster
 metadata:
   name: beam-flink-cluster
 spec:
+  flinkVersion: 1.10.1
   image:
     name: flink:1.10.1
-  jobManager:
-    resources:
-      limits:
-        memory: "1Gi"
   taskManager:
     replicas: 2
-    resources:
-      limits:
-        memory: "2Gi"
     sidecars:
       - name: beam-worker-pool
         image: apache/beam_python3.7_sdk:2.22.0