你好,現在我試圖運行一個pyflink腳本,可以連接到一個卡夫卡服務器。當我運行腳本,我得到了一個錯誤”時發生一個錯誤嚐試連接到Java服務器127.0.0.1:35529”。我需要安裝一個額外的jdk呢?
錯誤信息:
Py4JNetworkError:一個錯誤發生在試圖連接到Java服務器(127.0.0.1:35529)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
IndexError回溯(最近調用最後)
/磚/火花/ python / lib / py4j-0.10.9.1-src.zip / py4j / java_gateway。py _get_connection(自我)
976年試題:
- - > 977連接= self.deque.pop ()
978年除了IndexError:
IndexError:流行從一個空的雙端隊列
在處理上述例外,另一個例外發生:
ConnectionRefusedError回溯(最近調用最後)
/磚/火花/ python / lib / py4j-0.10.9.1-src.zip / py4j / java_gateway。在開始py(自我)
1114年試題:
- > 1115 self.socket.connect((自我。地址,self.port))
1116年的自我。流= self.socket.makefile (rb)
ConnectionRefusedError (Errno 111):連接拒絕了
在處理上述例外,另一個例外發生:
Py4JNetworkError回溯(最近調用最後)
模塊在< <命令- 1981093759856396 > >
88年
89年
推薦- - - - - - > 90 main ()
<命令- 1981093759856396 >在main ()
5 def main ():
6 #創建流環境
- - - - - > 7 env = StreamExecutionEnvironment.get_execution_environment ()
8
9設置= EnvironmentSettings.new_instance () \
/磚/ python / lib / python3.8 /網站/ pyflink / datastream數據/ stream_execution_environment。py get_execution_environment ()
801”“”
802網關= get_gateway ()
- - > 803 j_stream_exection_environment = gateway.jvm.org.apache.flink.streaming.api.environment \
804年.StreamExecutionEnvironment.getExecutionEnvironment ()
805年返回StreamExecutionEnvironment (j_stream_exection_environment)
/磚/火花/ python / lib / py4j-0.10.9.1-src.zip / py4j / java_gateway。py __getattr__(自我,名稱)
1690年返回UserHelpAutoCompletion ()
1691年
- > 1692回答= self._gateway_client.send_command (
1693原型。REFLECTION_COMMAND_NAME +
1694原型。REFL_GET_UNKNOWN_SUB_COMMAND_NAME +名稱+“\ n”+自我。_id +
/磚/火花/ python / lib / py4j-0.10.9.1-src.zip / py4j / java_gateway。py send_command(自我,指揮、重試、二進製)
1029如果“二進製”是“真”。
1030”“”
- > 1031連接= self._get_connection ()
1032年試題:
