Input data buffer for multiple downstream operators in parallel in Flink

I want to know how Flink handles branching out the result of one operator to multiple downstream operators. If I have an operator A that is connected to 3 other operators B, C and D in parallel, does Flink keep only one copy of the result and send it out to all 3 operators? Assuming that's the case, is the result removed once it has been sent to all 3 operators or is there a garbage collection process?

I haven't found anything concrete about this topic in the Flink documentation. Any relevant resource regarding this topic is highly appreciated.

Solution

Before sending record A to operators B, C, D, FLINK serialise record A into bytes. Then those bytes will be copied into buffer pools for sub-partitions for different operators, so there will be multiple copies of record A.

Record A will be GC later.

Which direction does memory-mapped segment of a process's virtual address space grow by default?
Linker and Memory map for shared memory in autosar embedded environment
How to force JavaScript to deep copy a string?
Is it efficient to use realloc to free up small chunks of memory C++
Should Polars Enum Datatype Result in More Efficient Storage and Memory Footprint of DataFrame?
Is this the right way to combine Garbage collected with none Garbage collected code in D
Why is it called a Segmentation Fault?
Why is free() causing an error here without the else block?
In multilevel paging (OS), until which level we keep applying paging on Page Table
What is the significance of caddr_t and when is it used?
When are objects garbage collected in python?
" heap-use-after-free" error even when I am not accessing the deleted node of a binary tree
How to resolve the "unknown array size in delete" error when using a class with a flexible array member (FAM) and a non-trivial destructor?
Zephyr - C - Deep copy of struct produce unexpected result
How to use a lot of memory in node.js?
ASP.NET: How to test for server memory usage?
Why should we set -XX:InitialRAMPercentage and -XX:MaxRAMPercentage to the same value for cloud environment?
Attempted to read or write protected memory. This is often an indication that other memory is corrupt
Is this understanding correct: If an object stores everything in itself, copying it and moving it is actually the same thing?
How to Get Total Memory Usage of a Chrome Tab
Why does int **a = &(&val); result in an error in C++?
What is the meaning of the term arena in relation to memory?
What is uninitialized data for `empty()` in PyTorch
Simple array push in PHP exceeds allowed memory. (Allowed memory size of 33554432 bytes exhausted (tried to allocate 33554440 bytes) )
Limiting Memory Use in a *Large* Django QuerySet
How do I set up a freeable cache in Golang (i.e. I can free the memory when memory pressure is detected)?
C and C++: Freeing PART of an allocated pointer
Where primitives inside objects are actually stored
Issue using unsynchronized_pool_resource for a pmr::vector allocation
Mallocing int* inside of int** gives unexpected integer values in the first and sometimes second allocation