From 4b8224af780fdd80d1ab566cd61bf4d8c47973f6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Rafa=C5=82=20Solarski?= Date: Fri, 13 Sep 2024 15:20:04 +0200 Subject: [PATCH 1/3] Nussknacker image version set to staging-latest --- .env | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.env b/.env index 14076c1d..469de065 100644 --- a/.env +++ b/.env @@ -1 +1 @@ -NUSSKNACKER_VERSION=1.17.0 +NUSSKNACKER_VERSION=staging-latest From 97596a4fe587012bdb66a9f8c953435c4a169580 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mateusz=20Ko=C5=82odziejczyk?= Date: Tue, 24 Sep 2024 13:02:42 +0200 Subject: [PATCH 2/3] [NU-1790] Flink 1.19 adaptations (#194) --- docker-compose.yml | 4 ++-- flink/Dockerfile | 3 ++- flink/flink-properties.yml | 6 +++--- 3 files changed, 7 insertions(+), 6 deletions(-) diff --git a/docker-compose.yml b/docker-compose.yml index 042a19d3..a5c6a68f 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -229,7 +229,7 @@ services: build: context: ./flink/ args: - FLINK_VERSION: "1.18.1-scala_2.12-java11" + FLINK_VERSION: "1.19.1-scala_2.12-java11" no_cache: true restart: unless-stopped command: jobmanager @@ -246,7 +246,7 @@ services: build: context: ./flink/ args: - FLINK_VERSION: "1.18.1-scala_2.12-java11" + FLINK_VERSION: "1.19.1-scala_2.12-java11" no_cache: true restart: unless-stopped command: taskmanager diff --git a/flink/Dockerfile b/flink/Dockerfile index a3e33a4e..30d2cf42 100644 --- a/flink/Dockerfile +++ b/flink/Dockerfile @@ -16,10 +16,11 @@ RUN echo '#!/bin/sh' > /ex-docker-entrypoint.sh && \ COPY --from=lib_provider /libs/ /opt/flink/lib/ USER flink -COPY flink-properties.yml /opt/flink/conf/ RUN mkdir -p /opt/flink/data && \ chmod -R 777 /opt/flink/data +COPY flink-properties.yml /opt/flink/conf/ + VOLUME /opt/flink/data ENTRYPOINT [ "/ex-docker-entrypoint.sh" ] diff --git a/flink/flink-properties.yml b/flink/flink-properties.yml index 12f45da9..d0494c46 100644 --- a/flink/flink-properties.yml +++ b/flink/flink-properties.yml @@ -1,6 +1,6 @@ taskmanager.numberOfTaskSlots: 8 -state.backend: filesystem +state.backend.type: filesystem state.checkpoints.dir: file:///opt/flink/data/checkpoints state.savepoints.dir: file:///opt/flink/data/savepoints @@ -21,8 +21,8 @@ metrics.reporter.influxdb_reporter.port: 8087 metrics.reporter.influxdb_reporter.db: nussknacker_metrics metrics.reporter.influxdb_reporter.scope.variables.excludes: tm_id;job_id;task_id;task_attempt_id;operator_id;task_attempt_num;task_name metrics.scope.jm: local..jobmanagerGlobal -metrics.scope.jm.job: local..jobmanagerJob. +metrics.scope.jm-job: local..jobmanagerJob. metrics.scope.tm: local..taskmanagerGlobal. -metrics.scope.tm.job: local..taskmanagerJob.. +metrics.scope.tm-job: local..taskmanagerJob.. metrics.scope.task: local..taskmanagerTask.... metrics.scope.operator: local..taskmanagerTask.... From e5d174d76c1a9015d5f149a56fd2b8c1fc00e995 Mon Sep 17 00:00:00 2001 From: Arek Burdach Date: Fri, 22 Nov 2024 13:31:28 +0100 Subject: [PATCH 3/3] version bump --- .env | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.env b/.env index 469de065..5182dee8 100644 --- a/.env +++ b/.env @@ -1 +1 @@ -NUSSKNACKER_VERSION=staging-latest +NUSSKNACKER_VERSION=1.18.0