I’m curious why it seems like a TimelyFlatMapFunction can’t be used with a regular DataStream, but it can be used with a KeyedStream.
Or maybe I’m missing something obvious (this is with 1.2-SNAPSHOT, pulled today). Also the documentation of TimelyFlatMapFunction (https://ci.apache.org/projects/flink/flink-docs-master/api/java/index.html?org/apache/flink/streaming/api/functions/TimelyFlatMapFunction.html <https://ci.apache.org/projects/flink/flink-docs-master/api/java/index.html?org/apache/flink/streaming/api/functions/TimelyFlatMapFunction.html>) shows using it with a DataStream.flatMap(xxx) call. Thanks, — Ken -------------------------- Ken Krugler +1 530-210-6378 http://www.scaleunlimited.com custom big data solutions & training Hadoop, Cascading, Cassandra & Solr
