pip list | grep apache apache-beam 2.27.0
apache-flink 1.13.2 apache-flink-libraries 1.13.2 $ python Python 3.7.5 (v3.7.5:5c02a39a0b, Oct 14 2019, 18:49:57) [Clang 6.0 (clang-600.0.57)] on darwin Type "help", "copyright", "credits" or "license" for more information. >>> import pyflink >>> pyflink.__file__ '/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/pyflink/__init__.py' >>> exit() $ cd /Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/pyflink (base) ChendeMacBook-Pro:pyflink chenshuai$ ls README.txtfind_flink_home.pyplugins __init__.pyfn_executionpyflink_callback_server.py __pycache__gen_protos.pypyflink_gateway_server.py binjava_gateway.pyserializers.py commonlibshell.py conflicensestable datasetlogutil datastreammetricsversion.py examplesopt $ bin/start-cluster.sh Starting cluster. [ERROR] The execution result is empty. [ERROR] Could not get JVM parameters and dynamic configurations properly. [ERROR] Raw output from BashJavaUtils: 错误: 找不到或无法加载主类 org.apache.flink.runtime.util.bash.BashJavaUtils [ERROR] The execution result is empty. [ERROR] Could not get JVM parameters and dynamic configurations properly. [ERROR] Raw output from BashJavaUtils: 错误: 找不到或无法加载主类 org.apache.flink.runtime.util.bash.BashJavaUtils 使用pyflink-shell local本地运行作业是没有问题的，现在想尝试远程运行作业。
