我们的使用是,我们希望使用flink流的去复制作业,它从源读取它的数据(kafka主题),并将独特的记录写入hdfs文件接收器。因此,我决定使用flink键状态流来实现去复制。toString) env.execute(applicationName)下面是使用flink的值状态进行去复制的代码with this key again }}
代码要求从2-5之间的数字输入计数到最多5,但最后一个要求是输出必须是文字数字。num = int(input('Enter a number (2-5): '))while count <= num: printnum = int(input('Enter a number (2-5): ')) count = count + 1Enter a number(<