因为执行完transformation之后，不能保证一定还是KeyedStream。如果确实还是KeyedStream，可以通过DataStreamUtils.reinterpretAsKeyedStream，声明成KeyedStream，不会引入keyBy。
> 在 2019年10月25日，下午4:05，Utopia <[email protected]> 写道： > > 大家好， > > KeyedStream 执行 transformation 以后不能变成 KeyedStream 吗，这样每次 transformation 都要重新 > keyBy，这样不太符合直觉，写的也很冗余。 > > 谢谢～
