你可以看看lib里面的包跟官网的要求是不是一样的
发自我的iPhone
-- Original --
From: Rainie Li https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deployment/hadoop.html
<
https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deployment/hadoop.html
Best,
那就是说datasream默认模式就是pipeline,而批模式是batch，批的模式是存在shuffle情况下，需要等shuffle操作造成，才能发送到下游.那如果批应用有shuffle操作和没有shuffle的，是都要等这个shuffle操作完成了才能一起发给下游，还是说其他非shuffle操作完成了可以先发给下游，不用等shuffle操作完成一起再发送？
发自我的iPhone
-- 原始邮件 --
发件人: Jingsong Li
lic static long getWindowStartWithOffset(long timestamp, long
offset,
gt; long windowSize) {
gt; amp;nbsp;nbsp; return timestamp - (timestamp - offset +
windowSize)
% windowSize;
gt; }
gt;
gt; 在 2020/4/4 下午6:30，“忝忝向仧”<153488...@qq.comamp;gt; 写入:
gt;
gt; amp;nbsp;amp;nbsp;amp;nbsp; 额，你的意思
.10/zh/dev/event_timestamps_watermarks.html
相关代码
public static long getWindowStartWithOffset(long timestamp, long offset,
long windowSize) {
nbsp; return timestamp - (timestamp - offset + windowSize) %
windowSize;
}
在 2020/4/4 下午6:30，“忝忝向仧”<153488...@qq.comgt; 写入:
nbsp;nbsp;nbsp; 额，你的意思是滚动3秒的窗口开
quot;https://ci.apache.org/projects/flink/flink-docs-release-1.10/zh/dev/event_timestamps_watermarks.html
相关代码
public static long getWindowStartWithOffset(long timestamp, long offset, long
windowSize) {
return timestamp - (timestamp - offset + windowSize) % windowSize;
}
在 2020/4/4 下午6:30，“忝忝向仧”<15348
html
相关代码
public static long getWindowStartWithOffset(long timestamp, long offset, long
windowSize) {
return timestamp - (timestamp - offset + windowSize) % windowSize;
}
在 2020/4/4 下午6:30，“忝忝向仧”<153488...@qq.com 写入:
额，你的意思是滚动3秒的窗口开始和结束应该是
100055000 % 3 得出结果再拿到[start,end).
比如1000
额，你的意思是滚动3秒的窗口开始和结束应该是
100055000 % 3 得出结果再拿到[start,end).
比如100055000 % 3 的结果是100053000,那么窗口是[100053000,100056000)
是这么理解吧
--原始邮件--
发件人:"lee.roval"
对，我只是回复把前面那串省略了，没写.
[100053000,100056000),为什么是100053000开始?
我第一条输入的是
1,tom1,100055000
--原始邮件--
发件人:"libenchao"
