flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vinay Patil <vinay18.pa...@gmail.com>
Subject Junit Issue while testing Kafka Source
Date Wed, 25 May 2016 02:29:15 GMT
Hi,

I am able to read from a topic using FlinkKafkaConsumer and return the
result, however  when I am testing this scenario in Junit the result is
getting printed(kafkaStream.print()) but  I am not able to exit the Job,
env.execute keeps running,
I tried to return env.execute from method but that did not work either.

1) Is there any way to end the execution of job forcefully.
2) How do I test if the data has come from topic

   - One way I think of is to get the output of stream.print() in a
   PrintStream and check the result.(but not able to test this since job is
   not getting exited)

Please help with these issues

Regards,
Vinay Patil

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message