class starting in lower-case?), really in the
jar
file? It might be a wrongly generated protobuf class ...
>> sub Class is exit in Protobuf generated class. Please find the
attached class.
<http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/t1169/Selection_
Hi,
I am using flink 2.1.0 version and protobuf-java 2.6.1 version.
I am getting below exception for protobuf generated class. I have included
jar which is having that class.
Can you please help me to check it.
org.apache.beam.sdk.util.UserCodeException:
Hi Piotrek,
I was checking in Job manager machine logs, and dashboard. But actually
output string was recorded in taskmanager macine log file. I added InfluxDB
and verified, Received data is writing into influxDB.
Thank you very much for your support.
Thanks,
Shankara
--
Sent from
Hi,
I mean same code works fine in flink local setup. I can able to see
"Received Message from testkafka Topic : " on console when kafka
receive some message (Kafka Producer is in other machine and sending some
message frequently to testkafka topic).
*Submitted the Beam
Below is my setup
1. Kafka zookeeper and server in one machine (192.168.1.116) and
producer (192.168.1.100) and consumer (192.168.1.117) in another machine.
--> This work fine no issue
2. Running standalone beam application with kafka consumer --> This
work fine
3.
