Fix bad slaves naming

defaults/main.yml

@@ -32,7 +32,7 @@ flink_taskmanager_service_template_path: templates/flink-taskmanager.service.j2
 flink_history_service_template_path: templates/flink-history.service.j2
 flink_conf_yaml_template_path: templates/flink-conf.yaml.j2
 flink_masters_template_path: templates/masters.j2
-flink_slaves_template_path: templates/slaves.j2
+flink_workers_template_path: templates/workers.j2
 
 ### Configuration
 flink_configuration:
@@ -55,8 +55,8 @@ flink_manager_type: [jobmanager, taskmanager, history]
 # Masters, host:port array
 flink_masters: ['localhost:8081']
 
-# Slaves, hosts array
-flink_slaves: ['localhost']
+# Workers, hosts array
+flink_workers: ['localhost']
 
 ### Log configuration
 # flink_log4j_template_path: templates/log4j.properties.j2

molecule/multiplenodes/group_vars/all/flink.yml

@@ -28,4 +28,4 @@ flink_configuration:
   metrics.reporter.prometheus.port: 9249
 
 flink_masters: [ "{{ hostvars['flink-master1']['ansible_default_ipv4']['address'] }}:8081" ]
-flink_slaves: [ "{{ hostvars['flink-worker1']['ansible_default_ipv4']['address'] }}" ]
+flink_workers: [ "{{ hostvars['flink-worker1']['ansible_default_ipv4']['address'] }}" ]

tasks/config.yml

@@ -44,7 +44,7 @@
       - "log4j.properties"
       - "flink-conf.yml"
       - "masters"
-      - "slaves"
+      - "workers"
 
 - name: FLINK | Finding default config files
   find:
@@ -77,7 +77,7 @@
   with_items:
     - { template: "{{ flink_conf_yaml_template_path }}", file: flink-conf.yaml }
     - { template: "{{ flink_masters_template_path }}", file: masters }
-    - { template: "{{ flink_slaves_template_path }}", file: slaves }
+    - { template: "{{ flink_workers_template_path }}", file: workers }
   notify: restart flink
 
 - name: FLINK | Create log4j file

templates/workers.j2

@@ -0,0 +1,3 @@
+{% for worker in flink_workers %}
+{{ worker }}
+{% endfor %}