java8rt.jar源码-flink-broadcast-example:示例Flink广播状态模式

java8 rt.jar源码Flink 广播状态示例 这是一个正在进行的工作。 班级 类Dataserver将侦听端口 7777 上的连接，并将每秒两次向任何连接的套接字发送一个随机数 1-6。 类StateServer将侦听端口 7778 上的连接并允许在stdin上stdin整数。 输入的任何数字都将回显到所有连接的套接字。 BroadcastState将连接到两个套接字，并将端口 7777 上收到的数字乘以从端口 7778 收到的乘数。 跑步 从源构建一个胖罐子： mvn clean package 打开两个终端以启动两个服务器并观察它们的日志记录： make dataserver make stateserver （如果您的系统没有make工具，请参阅要使用的命令。） 您可以通过在 IDE 中运行BroadcastState来运行 Flink 作业。 这应该会启动一个嵌入式迷你 Flink 集群并显示日志； 由于作业使用PrintSinkFunction ，因此管道的输出在日志中。 在运行状态服务器的终端中输入乘数以查看正在处理的更新。 输出还将显示哪个 Flink 进程处理了