block
keyEncoder.flush();
// TODO Auto-generated catch block
keyOut.close();
// TODO Auto-generated catch block
} catch (Exception e) {
}
return keyOut.toByteArray();
}
From: Ghiya, Jay (GE Healthcare)
Sent: 18 May
Hi Team,
This is regarding Flink Kafka Sink. We have a usecase where we have headers and
both key and value as Avro Schema.
Below is the expectation in terms of intuitiveness for avro kafka key and value:
KafkaSink.>builder()
.setBootstrapServers(cloudkafkaBrokerAPI)
this sounds bit like a native memory leak, but these are in
general really tricky to debug. Let's start with simply getting some stats
about the actual memory usage.
Best,
D.
On Thu, Dec 2, 2021 at 7:49 AM Ghiya, Jay (GE Healthcare)
mailto:jay.gh...@ge.com>> wrote:
Hi Flink Team
Hi Flink Team,
Greetings from GE Healthcare team.
Here is a stackoverflow post for the same too posted by fellow dev here :
https://stackoverflow.com/questions/70068336/flink-job-not-getting-submitted-java-io-ioexception-cannot-allocate-memory
Summary of the post:
Here is the usecase and relev
