correct pyflink getting started part 1 source

Author: jaehyeon-kim

.vscode/settings.json

@@ -7,7 +7,7 @@
   "editor.tabSize": 2,
   "python.linting.pylintEnabled": false,
   "python.linting.flake8Enabled": false,
-  "python.linting.enabled": true,
+  "python.linting.enabled": false,
   "python.formatting.provider": "none",
   "python.formatting.blackPath": "black",
   "python.formatting.blackArgs": ["--line-length", "100"],

pyflink-getting-started-on-aws/local/Dockerfile

@@ -1,4 +1,4 @@
-FROM flink:1.15.4-scala_2.12
+FROM flink:1.15.2-scala_2.12
 
 ARG PYTHON_VERSION
 ENV PYTHON_VERSION=${PYTHON_VERSION:-3.8.10}

pyflink-getting-started-on-aws/local/build.sh

@@ -1,6 +1,4 @@
 #!/usr/bin/env bash
-PKG_ALL="${PKG_ALL:-no}"
-
 SCRIPT_DIR="$(cd $(dirname "$0"); pwd)"
 SRC_PATH=$SCRIPT_DIR/package
 rm -rf $SRC_PATH && mkdir -p $SRC_PATH/lib

pyflink-getting-started-on-aws/local/producer.py

@@ -5,7 +5,6 @@
 import typing
 import random
 import logging
-import re
 import dataclasses
 
 from kafka import KafkaProducer