Removed unnecessary function and fixed submit.py

Removed unnecessary function and fixed submit.py

logging topic names

the topic name in kafka repository seems to be empty, hence topic name is being logged.

switching back to old flink windowing

Update entrypoint.py

change the underlying windowing function, use the default one. new ones need debugging.

0.1.17

reverting back to the old env names

0.1.16

added logger info

0.1.15

changes the way .kube/config is accessed, now it will read from the pod environment.

0.1.14

• downgraded the pandas version for flink image to keep it compatible with flink version

0.1.13

• fixed the .docker-file for flink: added pip upgrade
• revert the .kube/config to default

0.1.12

Added canRead() in the .kube/config check

added logic to access history in pyflink using table api

added logic to access history in pyflink using table api