Re: CoProcessFunction processElement1 and processElement2

They are designed to avoid race condition. Get Outlook for Android From: Tan, Min Sent: Sunday, November 1, 2020 2:15:54 AM To: user Subject: CoProcessFunction processElement1 and processElement2 Hi, Can someone confirm that the proce

CoProcessFunction processElement1 and processElement2

Hi, Can someone confirm that the processElement1 and processElement2 are run sequentially? not in paradelle. Thank you very much in advance. Regards, Min E-mails can involve SUBSTANTIAL RISKS, e.g. lack of confidentiality, potential manipulation of contents and/or sender's address, incorre

Re: how to enable metrics in Flink 1.11

Hi, I wanted to check if anyone can help me with the logs. I have sent several emails but not getting any response. I'm running Flink 1.11 on EMR 6.1. I don't see any logs though I get this stdout error. I'm trying to upgrade Flink 1.8 to Flink 1.11 18:29:19.834 [flink-akka.actor.default-dispatc

Re: What does Kafka Error sending fetch request mean for the Kafka source?

Hi my flow is Kafka Source -> Transform -> JDBC Sink Kafka Source is configured as at least once and JDBC prevents duplicates with unique key constraint and duplicate is logged in separate table. So the destination data is exactly once. The duplicates happen every so often, looking at check point