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-
- KafkaIO() "no records have been read yet." Warni... amir bahmanyari
- Re: KafkaIO() "no records have been read yet.&qu... amir bahmanyari
- Re: KafkaIO() "no records have been read yet... Raghu Angadi
- Re: KafkaIO() "no records have been read... amir bahmanyari
- Re: KafkaIO() "no records have been ... Raghu Angadi
