Hi Team,

I have written a Flink Job which reads data in a List & then converts it to

 public static void main(String[] args) throws Exception {
  // set up execution environment
  StreamExecutionEnvironment env =
. . .
 List<DTO> list=processData( );
  DataStream<DTO> orderA = env.fromCollection(list);
  . . . .

If *list* is empty then code throws below exception on Flink UI & does not
execute the Job. How can I handle this?
I've tried using list != null or list ! = isEmpty() checks. But it
didn't work. Request to provide suggestions.

*Exception : *

[image: image.png]

Thanks  & Regards

Reply via email to