Search code examples
apache-flinkflink-streamingflink-sqlpyflink

Python Flink Connect to Remote Flink Environment

I have flink system running in a remote system.. say with IP as 10.XX.XX.XX and port as 6123. Now I would like to connect from another system using Pyflink using RemoteExecution Environment. I saw the docs https://ci.apache.org/projects/flink/flink-docs-stable/dev/python/table-api-users-guide/table_environment.html but its not clear. Any pointers please?

Solution

  • I believe it should be enough to do this:

    ./bin/flink run \
      --jobmanager <jobmanagerHost>:8081 \
      --python examples/python/table/batch/word_count.py

    See Submitting PyFlink Jobs, which is where I found this example.