Merge pull request #83 from pangeo-forge/fix-flink-test

Fix local flink test
pangeo-forge · Aug 20, 2023 · 5b2faba · 5b2faba
2 parents 78162c6 + db67f22
commit 5b2faba
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/.github/workflows/flink.yaml b/.github/workflows/flink.yaml
@@ -39,7 +39,7 @@ jobs:
 
     - name: Setup FlinkOperator
       run: |
-        FLINK_OPERATOR_VERSION=1.3.0
+        FLINK_OPERATOR_VERSION=1.5.0
         helm repo add flink-operator-repo https://downloads.apache.org/flink/flink-kubernetes-operator-${FLINK_OPERATOR_VERSION}
         helm install flink-kubernetes-operator flink-operator-repo/flink-kubernetes-operator --wait
 

diff --git a/tests/integration/test_flink.py b/tests/integration/test_flink.py
@@ -42,13 +42,13 @@ def test_flink_bake(minio):
             "pangeo-forge-runner",
             "bake",
             "--repo",
-            "https://github.com/pangeo-forge/gpcp-feedstock.git",
+            "https://github.com/pforgetest/gpcp-from-gcs-feedstock.git",
             "--ref",
-            "2cde04745189665a1f5a05c9eae2a98578de8b7f",
+            "beam-refactor",
             "-f",
             f.name,
         ]
-        proc = subprocess.run(cmd)
+        proc = subprocess.run(cmd, capture_output=True)
 
         assert proc.returncode == 0