search

lyft / flinkk8soperator

Kubernetes operator that provides control plane for managing Apache Flink applications
Apache License 2.0
563 stars 159 forks source link

taskmanager did not invoke python beam by beam-python/flink-operator-custom-resource.yaml #191

Open pzou1974 opened 4 years ago

pzou1974 commented 4 years ago

https://github.com/lyft/flinkk8soperator/blob/master/examples/beam-python/flink-operator-custom-resource.yaml I

did kubectl create -f flink-operator-custom-resource.yaml

but on the taskmgr pod log I did not see python example got invoked.

tweise commented 4 years ago

Hi, on the TM pod, you should see the Beam SDK worker process. Did Flink job start/terminate (check Flink UI)?

pzou1974 commented 4 years ago

Yes. I checked UI both taskmgr and jobmgr are running. but failed to find completed python job. Let me have one more test.