Hi Chesnay,
Thanks for your time. Much appreciated.
I am getting error on the below line:
val res:DataStream[String]=AsyncDataStream.unorderedWait(goodRecords,new
CassandraAsyncSink(),1000,TimeUnit.SECONDS,100)
Yes, earlier it was a wrong import but it is still giving me the below
error:
type
It would have good to clarify which line causes the error; as is I can
only guess.
Please make sure you use the scala variant of the AsyncDataStream
(org.apache.flink.streaming.api.scala.AsyncDataStream).
On 11/01/2022 21:32, Siddhesh Kalgaonkar wrote:
I am using below code to get the data f
