我们的使用是,我们希望使用flink流的去复制作业,它从源读取它的数据(kafka主题),并将独特的记录写入hdfs文件接收器。因此,我决定使用flink键状态流来实现去复制。toString) env.execute(applicationName)下面是使用flink的值状态进行去复制的代码with this key again }}
我用一个来自多个客户端的测试帐户进行了测试,结果是: Client1 -会话开始需要30-40秒- Windows 10 Client2 -会话启动需要17 -20秒- Windows 10 Client3 -会话开始需要7-10秒-会话开始需要30-50秒-会话开始需要7-10秒-会话开始需要7-10秒- Windows 7不包括上述客户端与RDS相同的域或网络,DNS是正确设置的。