getSessionUid)Exception in thread "main" java.lang.ArrayIndexOutOfBoundsException: -1 at org.apache.flink.api.java.typeutils.TypeExtractor.getKeySelector
如何根据不同的用例展开相同的keyedStream并应用过滤器,而无需在过滤结束时创建新的keyedStream?= null).keyBy(key -> key.id); /*wants to avoid this*/
KeyedStream<T,T> keyed2= streamFiltered.filter(under the same concept but with different filters applied to the keyedStream already cr