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

[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");