测试用例最后一个例子为什么会空指针异常

[CCweixiao]

测试用例最后一个例子为什么会空指针异常

   @Test
    public void testDynamicalStreamSimplePatternMatch2() throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        DataStream<Event> input1 = env.addSource(new RandomEventSource(30).setName("event_stream_1"));

        DataStream<ControlEvent> controlStream = env.addSource(new SourceFunction<ControlEvent>() {
            @Override
            public void run(SourceContext<ControlEvent> sourceContext) throws InterruptedException {
                sourceContext.collect(MetadataControlEvent.builder()
                        .addExecutionPlan("1", "from input select  *  insert into output;")
                        .build());
                sourceContext.collect(OperationControlEvent.enableQuery("1"));

            }

            @Override
            public void cancel() {
            }
        });
        SiddhiCEP cep = SiddhiCEP.getSiddhiEnvironment(env);
        cep.registerStream("input",input1,"id","name");
        cep.from("input")
                .cql(controlStream).returnAsRow("output").print();

        //SiddhiCEP.define("input", input1,"id","name")

        env.execute();
    }