[NU-1790] Flink 1.19 adaptations (#194)

Author: coutoPL

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

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" ]

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.<host>.jobmanagerGlobal
-metrics.scope.jm.job: local.<host>.jobmanagerJob.<job_name>
+metrics.scope.jm-job: local.<host>.jobmanagerJob.<job_name>
 metrics.scope.tm: local.<host>.taskmanagerGlobal.<tm_id>
-metrics.scope.tm.job: local.<host>.taskmanagerJob.<tm_id>.<job_name>
+metrics.scope.tm-job: local.<host>.taskmanagerJob.<tm_id>.<job_name>
 metrics.scope.task: local.<host>.taskmanagerTask.<tm_id>.<job_name>.<task_name>.<subtask_index>
 metrics.scope.operator: local.<host>.taskmanagerTask.<tm_id>.<job_name>.<operator_name>.<subtask_index>