[Flink错误总结]java.lang.NullPointerException: Keyed state can only be used on a ‘keyed stream‘

java.lang.NullPointerException: Keyed state can only be used on a 'keyed stream', i.e., after a 'keyBy()' operation.

在使用监控状态之前未将流转为keyed stream,导致出错.

        stream
                .keyBy(t -> t.f1.getSink_table())
                .addSink(FlinkSinkUtil.getPhoenixSink()).name("hbase sink");