flink streamlet Broadcast states are empty or Null while running testcases

[vimaleshJeyavelmani]

I tried to write some test cases for flink streamlets.

My blueprint contains two ingress that will listen kafka topics and one processor that will excute the tasks according to the inputs.

when I do "run Local" my cloudflow project is working fine. But while running testcases I am facing issue with broadcast values.

I broadcasted my 1st topic input and tried to use it in the process fuction but while running testcases my broadcase values are empty or null.

Please refer the repo https://github.com/vimaleshJeyavelmani/cloudFlow