I get an java.lang.ClassNotFoundException:
org.apache.flink.api.common.serialization.RuntimeContextInitializationContextAdapters
when running my Apache Flink code locally. It works fine when I use a local
generator for my DataStream. As soon as I switch to an AWS FlinkKinesisConsumer
to get me
Hi,
is there a http data stream as data source ?
I only see socketTextStream and other predefined stream sources.
It seems that I have to use fromCollection, fromElements ... and prepare the
collection for myself.
Thanks
Regards
