cumulate累加函数输出问题

能不能通过设置，每分钟只输出 当前小窗口中计算数据的结果，之前计算的结果不再输出 目前测试发现，输入的数据越多，到下次输出的数据也会越来越多， 不同窗口的计算结果，都会再下次窗口中输出，

spring????flinkclient????jar??????????

??     spring??jarjarflink??flinkclientjar??spring??jar??webjar??flinkjar?

怎么才能取消订阅呢

Re: 怎么才能取消订阅呢

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> 写道： > >

Re: cumulate累加函数输出问题

Hi！ 你可能想要的是 tumble window 而不是 cumulate window。 李航飞 于2021年8月20日周五 下午3:26写道： > 能不能通过设置，每分钟只输出 当前小窗口中计算数据的结果，之前计算的结果不再输出 > > > 目前测试发现，输入的数据越多，到下次输出的数据也会越来越多， > 不同窗口的计算结果，都会再下次窗口中输出， > >

Re:Re: cumulate累加函数输出问题

你好： 我使用的场景是要实时统计一天的数据，在小窗口进行即时输出，延迟不能太高，cumulate window符合要求，tumble window 延迟太高了。 在 2021-08-20 16:01:57，"Caizhi Weng" 写道： >Hi！ > >你可能想要的是 tumble window 而不是 cumulate window。 > >李航飞 于2021年8月20日周五 下午3:26写道： > >> 能不能通过设置，每分钟只输出 当前小窗口中计算数据的结果，之前计算的结果不再输出 >> >> >> 目前测试发现，输入的数据越多，到下次输出的数据也会越来越多， >> 不同

flink checkpoint 到hdfs 报错

// 开启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

Re:flink checkpoint 到hdfs 报错

这不很清楚么，连 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

Re:Re:flink checkpoint 到hdfs 报错

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

Re:Re:Re:flink checkpoint 到hdfs 报错

集群里的机器互相访问配的是内网地址呗，你这得开内网访问... 在 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，牛成 写道： 退订