[jira] [Created] (FLINK-4016) FoldApplyWindowFunction is not properly initialized

["RWenden (JIRA)" <ji...@apache.org>]

RWenden created FLINK-4016:
------------------------------

             Summary: FoldApplyWindowFunction is not properly initialized
                 Key: FLINK-4016
                 URL: https://issues.apache.org/jira/browse/FLINK-4016
             Project: Flink
          Issue Type: Bug
          Components: DataStream API
    Affects Versions: 1.0.3
            Reporter: RWenden
            Priority: Blocker
             Fix For: 1.1.0


FoldApplyWindowFunction's outputtype is not set.

We're using constructions like (excerpt):
      .keyBy(0)
      .countWindow(10, 5)
      .fold(...)
Running this stream gives an runtime exception in FoldApplyWindowFunction:
"No initial value was serialized for the fold window function. Probably the setOutputType method was not called."

This can be easily fixed in WindowedStream.java by (around line# 449):
            FoldApplyWindowFunction foldApplyWindowFunction = new FoldApplyWindowFunction<>(initialValue, foldFunction, function);
            foldApplyWindowFunction.setOutputType(resultType, input.getExecutionConfig());

            operator = new EvictingWindowOperator<>(windowAssigner,
                    windowAssigner.getWindowSerializer(getExecutionEnvironment().getConfig()),
                    keySel,
                    input.getKeyType().createSerializer(getExecutionEnvironment().getConfig()),
                    stateDesc,
                    new InternalIterableWindowFunction<>(foldApplyWindowFunction),
                    trigger,
                    evictor);





--
This message was sent by Atlassian JIRA
(v6.3.4#6332)