一、Linux nc命令

-l 开启监听模式,用于指定nc将处于监听模式。通常这样代表着为一个服务等待客户端来链接指定的接口。

-p <通信端口>:设置本地主机使用的通信端口。有可能会关闭。

-k <通信端口>:强制nc待命链接。当客户端从服务端断开连接后,过一段时间服务端也会停止监听。但通过选项-k可以强制服务器保持连接并继续监听端口。

二、使用shell终端(local模式)

Flink附带了一个集成的交互式Scala shell,它可以在本地模式和群集模式中使用。通过flink的scala-shell终端程序可以快速上手flink,并可以对简单的flink任务进行调试和测试。类似于Spark的shell终端。

要将shell与集成的flink集群一起使用,只需执行:bin/start-scala-shell.sh local。该命令集成了flink的执行环境,所以不需要启动flink集群。

Scala Shell支持batch和Streaming。启动后会自动预先绑定两个不同的执行环境。可以使用’benv’和’senv’变量来分别访问batch和Streaming环境。

./start-scala-shell.sh –help查看帮助信息,该命令支持remote和yarn集群模式,并且可以通过该命令来添加外部依赖的jar包。

  • 使用batch环境在Scala shell中执行WordCount

./start-scala-shell.sh local

Flink使用shell终端(local模式)

print()命令会自动将指定的任务发送到JobManager执行,并在终端中显示计算结果。

也可以将结果写入文件。但是,在这种情况下,就需要调用execute,来运行程序:

benv.execute.(“MyProgram”)

注:只有local模式下才会把输出打印到终端,若是集群模式将不会打印到终端。

  • 使用Streaming环境在Scala shell中通过DataStream API计算WordCount

./start-scala-shell.sh local

Flink使用shell终端(local模式)

注:在Streaming环境下,打印操作不会直接触发执行。

相关文章:

  • 2021-04-09
  • 2022-12-23
  • 2021-12-08
  • 2021-06-01
  • 2021-08-30
  • 2022-03-02
  • 2021-11-12
  • 2022-12-23
猜你喜欢
  • 2021-12-29
  • 2021-09-06
  • 2022-01-08
  • 2022-01-13
  • 2021-12-10
  • 2022-12-23
相关资源
相似解决方案