Hi All,
I am wondering how to run multiple DStream transformations using Livy
without creating multiple streaming contexts? This seems be tricky compared
to running multiple transformations on structured streaming.
So every time I spawn a job via Livy I want to a new Dstream transformation
to run. is that possible? I am running into two errors
1) Cannot create multiple streaming contexts. Not that I wish to but I want
to be able to run multiple dstream transformations so whatever efficient
way exists I am fine
2) Whenever I spawn a job via livy I hit this line and it would throw an
illegal state exception. I am not sure how to get around this
KafkaUtils.createDirectStream(
jssc,
LocationStrategies.PreferConsistent(),
ConsumerStrategies.<String, byte
[]>Subscribe(topics, consumerConfig)
);
Thanks!