On Mon, Apr 15, 2024 at 16:17 Niklas Wilcke wrote:
> Hi Flink Community,
> u
> I wanted to reach out to you to get some input about Pyflink performance.
> Are there any resources available about Pyflink benchmarks and maybe a
> comparison with the Java API? I wasn't able to find something valuabl
Hi there,
I'm writing for knowledge about SerializationSchema/DeserializationSchema's
concurrency safety.
The problem is, I've implemented my own
KafkaSerializationSchema/KafkaDeserializationKafka which I have added some
internal state and object cache as to avoid heavy object(memory)
allocation.
