Hi Robert,
It seems the retrieved address of JobManager is a cluster-internal Ip that
can noly be accessed inside the cluster. As you said, you might need to
create an ingress to expose the JobManager service so that the client can
access to it outside of the k8s cluster.
Best,
Shuiqiang
Robert
Attempting to run the word_count.py example on my kubernetes (session)
cluster:
./bin/flink run \
--target kubernetes-session \
-Dkubernetes.cluster-id=cmdaa \
-Dkubernetes.container.image=cmdaa/pyflink:0.0.1 \
--pyModule word_count \
--pyFiles /opt/flink-1.12.2/examples/python/table/batch/word_co
