美文网首页flink大法大数据
如何跑SocketTextStreamWordCount(qui

如何跑SocketTextStreamWordCount(qui

作者: jackie_shawn | 来源:发表于2017-03-07 16:49 被阅读63次

    官方文档中只给了wordcount的输入输出示例,直接右键run main就可以了。但到了跑SocketTextStreamWordCount,由于程序是需要接收参数的,直接run main会保缺少参数的错误:

    直接run main

    当然你可以导出编译好的jar包来运行,不过又麻烦而且不够直观。

    首先你需要使用命令:“nc -lk 9080”来用netcat开启本机socket连接并制定端口“9080”,然后在Edit configurations里面设置运行程序接收的参数

    Edit configuration中编辑运行配置 设置运行程序的参数

    然后右键run main,在命令行中输入文本,就可以交由flink计算了:

    输入要计算的文本 计算结果

    相关文章

      网友评论

        本文标题:如何跑SocketTextStreamWordCount(qui

        本文链接:https://www.haomeiwen.com/subject/zgxtgttx.html