Hi Colleagues,I am running a Beam app on a 4-nodes Flink Cluster while 
receiving data from a single Kafka server.In all nodes 
flink-abahman-taskmanager-0-beam2.log file, I see continuesly see this Warning 
message as data is processed:2016-09-08 21:52:26,523 WARN  
org.apache.beam.sdk.io.kafka.KafkaIO                          - Reader-19: 
getWatermark() : no records have been read yet.
What is this? Does it mean maybe losing tuples? How can I enhance the KafkaIO() 
call to not seeing this Warning?Thanks+regardsAmir-

Reply via email to