[FLINK-1956] Runtime context not initialized in RichWindowMapFunction

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.9
• Component/s: API / DataStream
• Labels: context runtime streaming window
• Assignee: Márton Balassi
• Reporter: Daniel Bali
• Created: 29/Apr/15 10:32
• Updated: 28/Feb/19 11:15
• Resolved: 05/May/15 10:19

Description

Trying to access the runtime context in a rich window map function results in an exception. The following snippet demonstrates the bug:

    env.generateSequence(0, 1000)
    .window(Count.of(10))
    .mapWindow(new RichWindowMapFunction<Long, Tuple2<Long, Long>>() {
        @Override
        public void mapWindow(Iterable<Long> input, Collector<Tuple2<Long, Long>> out) throws Exception {
            long self = getRuntimeContext().getIndexOfThisSubtask();
            for (long value : input) {
                out.collect(new Tuple2<>(self, value));
            }
        }
    }).flatten().print();