有人知道如何测试窗口功能吗 Flink ? 我正在使用依赖关系 flink-test-utils_2.11 .
我的步骤是：
去拿那个 StreamExecutionEnvironment 创建对象并添加到环境中
做一个 keyBy 添加会话窗口
执行聚合函数

public class AggregateVariantCEVTest extends AbstractTestBase {

   @Test
    public void testAggregateVariantCev() throws Exception  {
       StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
       env.setParallelism(1);

       env.fromElements(objectOne, objectTwo)
               .keyBy(new KeyedByMyCustomKey())
               .window(EventTimeSessionWindows.withGap(Time.seconds(1)))
               .aggregate(new MyAgreggateFunction());

       JobExecutionResult result = env.execute();

       assertEquals(myExpectedResults, result.getAllAccumulatorResults());

   }
}

问题是 result.getAllAccumulatorResults() 大小为0。
你知道我做错了什么吗？提前谢谢！