diff --git a/.env b/.env index 14076c1d..5182dee8 100644 --- a/.env +++ b/.env @@ -1 +1 @@ -NUSSKNACKER_VERSION=1.17.0 +NUSSKNACKER_VERSION=1.18.0 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....