提交 6452ca06 编写于 作者: G ghermann 提交者: Stephan Ewen

[streaming] Fixed java 1.6 error

上级 b39305f8
......@@ -53,7 +53,7 @@ public class StreamWindowTask extends FlatMapFunction<Tuple, Tuple> {
@Override
public void flatMap(Tuple value, Collector<Tuple> out) throws Exception {
long progress = value.getField(windowFieldId);
long progress = (Long) value.getField(windowFieldId);
if (initTimestamp == -1) {
initTimestamp = progress;
nextTimestamp = initTimestamp + computeGranularity;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册