Hey Team,

I have a flow like Kafka Sink Datastream -> Process Function (Separate
Class) -> DBSink(Separate Class).

Process Function returns me the output as a string and now I want to create
a DataStream out of the string variable so that I can call something like
ds.addSink(new DBSink()). For that, I used the StreamExecution variable as
a global /method variable but I am not able to create it properly.

What is happening is, if I don't create a data stream properly it doesn't
call the sink properly because it doesn't execute the methods under the
Sink class which is according to Fabian's answer in the below post:

https://stackoverflow.com/questions/41210266/apache-flink-use-values-from-a-data-stream-to-dynamically-create-a-streaming-d

How can I fix this? Or else, I will have to create normal classes and call
the DB methods which is inappropriate because it will create and close
connection per record which is again an expensive operation in practice.

Thanks,
Sid

Reply via email to