flink key by 后的 process 不执行？

DataStreamSource scanJobStreamSource = KafkaUtil.getStreamSource(env, prop.getProperty("bootstrap.servers"), prop.getProperty("group.id"),"kuai2", new PoJoDeserializationSchema(ScanInfo.class,false));

scanJobStreamSource.map(new ScanInfoJobMapfunction()).name("ScanInfo2ScanWrapInfo")

.keyBy((KeySelector<ScanWrapInfo, String>) scanWrapInfo -> scanWrapInfo.getJobCode()) .process(new JobCodeKeyProcessFunction())

    .name("JobCodeKeyProcessFunction").print();

    keyBy之后一直显示运行，debug 也显示 the application is running，但是数据卡在keyBy这里。