我应该为 运行 SocketTextStreamWordCount 示例选择哪个端口
What port should I choose to run the SocketTextStreamWordCount sample
感受我对 Flink 的看法。我从 quickstart 生成了 SocketTextStreamWordCount 并很快发现了推荐的用法
SocketTextStreamWordCount <host> <port>
但是,我不知道选择什么端口。 QuickStart 文档没有透露太多内容,虽然我怀疑我需要将 JobManager 的端口作为参数提交,但当我配置 default port (6123 ).
感谢任何帮助或提示。
SocketTextStreamWordCount
示例程序从网络套接字接收输入。程序的端口参数不是指 JobManager 端口,而是程序连接读取输入的套接字端口。因此你必须先打开一个套接字才能启动程序。
来自 SocketTextStreamWordCount.java
class 的 JavaDocs:
This example shows an implementation of WordCount with data from a
text socket. To run the example make sure that the service providing
the text data is already up and running.
To start an example socket text stream on your local machine run
netcat from a command line: nc -lk 9999
, where the parameter
specifies the port number.
如果您遵循这些说明,您应该按照
执行程序
SocketTextStreamWordCount localhost 9999
感受我对 Flink 的看法。我从 quickstart 生成了 SocketTextStreamWordCount 并很快发现了推荐的用法
SocketTextStreamWordCount <host> <port>
但是,我不知道选择什么端口。 QuickStart 文档没有透露太多内容,虽然我怀疑我需要将 JobManager 的端口作为参数提交,但当我配置 default port (6123 ).
感谢任何帮助或提示。
SocketTextStreamWordCount
示例程序从网络套接字接收输入。程序的端口参数不是指 JobManager 端口,而是程序连接读取输入的套接字端口。因此你必须先打开一个套接字才能启动程序。
来自 SocketTextStreamWordCount.java
class 的 JavaDocs:
This example shows an implementation of WordCount with data from a text socket. To run the example make sure that the service providing the text data is already up and running.
To start an example socket text stream on your local machine run netcat from a command line:
nc -lk 9999
, where the parameter specifies the port number.
如果您遵循这些说明,您应该按照
执行程序SocketTextStreamWordCount localhost 9999