Skip to content

Commit

Permalink
[Bug][scaleph-engine-flink-kubernetes] change scaleph-file-fetcher ia…
Browse files Browse the repository at this point in the history
…mge from dev to release (#567)

fix: change scaleph-file-fetcher iamge from dev to release
  • Loading branch information
kalencaya authored Jul 9, 2023
1 parent 0ca2fb1 commit 46bc7da
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion .github/workflows/docker-sql-template.yml
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ jobs:
- name: Set up Docker Buildx
uses: docker/setup-buildx-action@v2
- name: Build scaleph-sql-template
run: cd scaleph/scaleph-engine/scaleph-sql-template && \
run: cd scaleph-engine/scaleph-sql-template && \
mvn -B -U clean package -DskipTests -Dfast
- name: Build image
uses: docker/build-push-action@v4
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,8 +34,7 @@ public enum FileFetcherFactory implements ResourceCustomizer<WsFlinkKubernetesJo

public static final String FLINK_MAIN_CONTAINER_NAME = "flink-main-container";
private static final String FILE_FETCHER_CONTAINER_NAME = "scaleph-file-fetcher";
// private static final String FILE_FETCHER_CONTAINER_IMAGE = "ghcr.io/flowerfine/scaleph/scaleph-file-fetcher:latest";
private static final String FILE_FETCHER_CONTAINER_IMAGE = "scaleph-file-fetcher:dev";
private static final String FILE_FETCHER_CONTAINER_IMAGE = "ghcr.io/flowerfine/scaleph/scaleph-file-fetcher:latest";

private static final Map<String, Quantity> FILE_FETCHER_CONTAINER_CPU = Map.of("cpu", Quantity.parse("250m"));
private static final Map<String, Quantity> FILE_FETCHER_CONTAINER_MEMORY = Map.of("memory", Quantity.parse("512Mi"));
Expand Down Expand Up @@ -173,6 +172,7 @@ private List<VolumeMount> buildVolumeMount() {
flinkLib.withMountPath(LIB_DIRECTORY);
return Arrays.asList(scalephLib.build(), flinkLib.build());
}

private List<Volume> buildVolume() {
VolumeBuilder scalephLib = new VolumeBuilder();
scalephLib.withName(FILE_FETCHER_SCALEPH_VOLUME_NAME);
Expand Down

0 comments on commit 46bc7da

Please sign in to comment.