Hi
退订应该发送到 user-zh-unsubscr...@flink.apache.org
Best
JasonLee
在2021年08月21日 09:43,牛成 写道:
退订
退订
退订
集群里的机器互相访问配的是内网地址呗,你这得开内网访问...
在 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 超时啊
>>
>>
>>
>>
>>在
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,
这不很清楚么,连 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",
// 开启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
你好:
我使用的场景是要实时统计一天的数据,在小窗口进行即时输出,延迟不能太高,cumulate window符合要求,tumble window 延迟太高了。
在 2021-08-20 16:01:57,"Caizhi Weng" 写道:
>Hi!
>
>你可能想要的是 tumble window 而不是 cumulate window。
>
>李航飞 于2021年8月20日周五 下午3:26写道:
>
>> 能不能通过设置,每分钟只输出 当前小窗口中计算数据的结果,之前计算的结果不再输出
>>
>>
>> 目前测试发现,输入的数据越多,到下次输出的数据也会越来越多,
>>
Hi!
你可能想要的是 tumble window 而不是 cumulate window。
李航飞 于2021年8月20日周五 下午3:26写道:
> 能不能通过设置,每分钟只输出 当前小窗口中计算数据的结果,之前计算的结果不再输出
>
>
> 目前测试发现,输入的数据越多,到下次输出的数据也会越来越多,
> 不同窗口的计算结果,都会再下次窗口中输出,
>
>
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 Chenyu,
這確實是目前尚未解決的一個問題,相關的 jira issue 可以看這 [1]。
jira issue 底下的討論串有提到一個替代方案是:使用 -D\$internal.pipeline.job-id=$(cat
/proc/sys/kernel/random/uuid|tr -d "-") 主動為 application 模式的任務產生隨機的 jobid。
但由於此配置參數屬於 flink 內部參數,可能不保證未來任何改動後的向後兼容性,請謹慎考慮後再使用。
[1]
15 matches
Mail list logo