Fix the secret name reference

decodableco · Jul 19, 2024 · e5cbcef · e5cbcef
1 parent 4dcad26
commit e5cbcef
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pyflink-decodable/main.py b/pyflink-decodable/main.py
@@ -34,11 +34,11 @@ def get_user_name(id):
     return jmespath.search("name", json.loads(r.text))
 
 def process_todos():
-    with open('/opt/pipeline-secrets/gm_todo_kafka_user_name', 'r') as file:
+    with open('/opt/pipeline-secrets/todo_kafka_user_name', 'r') as file:
       user_name = file.read()
-    with open('/opt/pipeline-secrets/gm_todo_kafka_password', 'r') as file:
+    with open('/opt/pipeline-secrets/todo_kafka_password', 'r') as file:
       password = file.read()
-    with open('/opt/pipeline-secrets/gm_todo_kafka_bootstrap_servers', 'r') as file:
+    with open('/opt/pipeline-secrets/todo_kafka_bootstrap_servers', 'r') as file:
       bootstrap_servers = file.read()
 
     env = StreamExecutionEnvironment.get_execution_environment()