能不能通过设置,每分钟只输出 当前小窗口中计算数据的结果,之前计算的结果不再输出
目前测试发现,输入的数据越多,到下次输出的数据也会越来越多,
不同窗口的计算结果,都会再下次窗口中输出,
??
spring??jarjarflink??flinkclientjar??spring??jar??webjar??flinkjar?
To remove your address from the list, send a message to:
mailto:user-zh-unsubscr...@flink.apache.org>>
> 2021年8月20日 下午3:36,18221112048 <18221112...@163.com> 写道:
>
>
Hi!
你可能想要的是 tumble window 而不是 cumulate window。
李航飞 于2021年8月20日周五 下午3:26写道:
> 能不能通过设置,每分钟只输出 当前小窗口中计算数据的结果,之前计算的结果不再输出
>
>
> 目前测试发现,输入的数据越多,到下次输出的数据也会越来越多,
> 不同窗口的计算结果,都会再下次窗口中输出,
>
>
你好:
我使用的场景是要实时统计一天的数据,在小窗口进行即时输出,延迟不能太高,cumulate window符合要求,tumble window 延迟太高了。
在 2021-08-20 16:01:57,"Caizhi Weng" 写道:
>Hi!
>
>你可能想要的是 tumble window 而不是 cumulate window。
>
>李航飞 于2021年8月20日周五 下午3:26写道:
>
>> 能不能通过设置,每分钟只输出 当前小窗口中计算数据的结果,之前计算的结果不再输出
>>
>>
>> 目前测试发现,输入的数据越多,到下次输出的数据也会越来越多,
>> 不同
// 开启checkpoint
env.enableCheckpointing(5000L, CheckpointingMode.EXACTLY_ONCE);
env.getCheckpointConfig().setCheckpointStorage("hdfs://test.gl.cdh.node1:8020/flink/flink-cdc-demo");
System.setProperty("HADOOP_USER_NAME", "root");
报错信息如下:
org.apache.hadoop.net.ConnectTimeoutException: 6 milli
这不很清楚么,连 192.168.0.32:9866 超时啊
在 2021-08-20 18:13:10,"杨帅统" 写道:
>// 开启checkpoint
>env.enableCheckpointing(5000L, CheckpointingMode.EXACTLY_ONCE);
>
>env.getCheckpointConfig().setCheckpointStorage("hdfs://test.gl.cdh.node1:8020/flink/flink-cdc-demo");
>System.setProperty("HADOOP_USER_NAME", "roo
test.gl.cdh.node1 对应的是远程服务器外网地址 139.9.132.*
192.168.0.32:9866是139.9.132.*机器的同一内网下的另一台内网地址 为啥会返回内网地址啊。。。
在 2021-08-20 18:28:34,"东东" 写道:
>这不很清楚么,连 192.168.0.32:9866 超时啊
>
>
>
>
>在 2021-08-20 18:13:10,"杨帅统" 写道:
>>// 开启checkpoint
>>env.enableCheckpointing(5000L, CheckpointingMod
集群里的机器互相访问配的是内网地址呗,你这得开内网访问...
在 2021-08-20 18:56:58,"杨帅统" 写道:
>
>
>
>
>
>
>test.gl.cdh.node1 对应的是远程服务器外网地址 139.9.132.*
>192.168.0.32:9866是139.9.132.*机器的同一内网下的另一台内网地址 为啥会返回内网地址啊。。。
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>在 2021-08-20 18:28:34,"东东" 写道:
>>这不很清楚么,连 192.168.0.32:9866 超时啊
>>
>>
>>
>>
>>在 202
退订
退订
Hi
退订应该发送到 user-zh-unsubscr...@flink.apache.org
Best
JasonLee
在2021年08月21日 09:43,牛成 写道:
退订
14 matches
Mail list logo