diff --git a/.github/workflows/flink.yaml b/.github/workflows/flink.yaml index 81a04284..cd71dccb 100644 --- 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 index 631c44e3..65202afd 100644 --- 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