Commands:

Setup

chmod +x setup.sh ./setup.sh

${FLINK_HOME}/bin/flink run --jobmanager localhost:8081 --python word_count.py

Name		Name	Last commit message	Last commit date
Latest commit History 18 Commits
.gitea/workflows		.gitea/workflows
connector_jars		connector_jars
.gitignore		.gitignore
README.md		README.md
kafka_stream.py		kafka_stream.py
kafka_stream_to_hdfs.py		kafka_stream_to_hdfs.py
requirements.txt		requirements.txt
setup.sh		setup.sh
word_count.py		word_count.py