Hi Chesnay, just one downstream: Sin (Source: Enriched Code) outcome is the
right part of the following operator as in the figure; this operator is the
exclusive downstream of Sin.
Thanks,
[image: Screenshot 2019-06-14 at 13.52.52.png]
Il giorno ven 14 giu 2019 alle ore 12:23 Chesnay Schepler <
c
How does the *P1 *pipeline look like? Are there 2 downstream operators
reading from *Sin* (in this case the number of bytes would be measured
twice)?
On 14/06/2019 12:09, Andrea Spina wrote:
Sorry, I totally missed the version: flink-1.6.4, Streaming API
Il giorno ven 14 giu 2019 alle ore 11:
Sorry, I totally missed the version: flink-1.6.4, Streaming API
Il giorno ven 14 giu 2019 alle ore 11:08 Chesnay Schepler <
ches...@apache.org> ha scritto:
> Which version of Flink are you using? There were some issues at some point
> about double-counting.
>
> On 14/06/2019 09:49, Andrea Spina w
Which version of Flink are you using? There were some issues at some
point about double-counting.
On 14/06/2019 09:49, Andrea Spina wrote:
Dear Community, I'd like to ask for some details about bytes related
metrics in Flink. Precisely, I'm looking at *bytes sent* and *bytes
received *metrics:
Dear Community, I'd like to ask for some details about bytes related
metrics in Flink. Precisely, I'm looking at *bytes sent* and *bytes
received *metrics: what I am recording is the following:
I am reading from a Kafka topic *A* records with schema *K* using a source *Sin
*belonging to a pipeline
