Fix: Inconsistent table names in Flink Kafka Sinks. (#287)

* Fix: bootcamp\materials\4-apache-flink-training\src\job\start_job.py

* Update start_job.py

---------

Co-authored-by: PrinceSajjadHussain <[email protected]>

Author: PrinceSajjadHussain

bootcamp/materials/4-apache-flink-training/src/job/start_job.py

@@ -4,9 +4,8 @@
 import json
 import requests
 from pyflink.table import EnvironmentSettings, DataTypes, TableEnvironment, StreamTableEnvironment
-
 def create_processed_events_sink_kafka(t_env):
-    table_name = "process_events_kafka"
+    table_name = "raw_events_kafka"
     kafka_key = os.environ.get("KAFKA_WEB_TRAFFIC_KEY", "")
     kafka_secret = os.environ.get("KAFKA_WEB_TRAFFIC_SECRET", "")
     sasl_config = f'org.apache.kafka.common.security.plain.PlainLoginModule required username="{kafka_key}" password="{kafka_secret}";'