Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-7058

Python SDK: Collect metrics in non-cython environment

    XMLWordPrintableJSON

    Details

      Description

      With the portable Flink runner, the metric is reported as 0, while the count metric works as expected.

      https://lists.apache.org/thread.html/25eec8104bda6e4c71cc6c5e9864c335833c3ae2afe225d372479f30@%3Cdev.beam.apache.org%3E

       Edit: metrics are collected properly when using cython, but not without cython. This is because state sampling has yet to be implemented in a way that does not depend on cython [1].

      [1] https://github.com/apache/beam/blob/master/sdks/python/apache_beam/runners/worker/statesampler_slow.py#L62

        Attachments

        1. test-metrics.txt
          25 kB
          Ankur Goenka

          Activity

            People

            • Assignee:
              ajamato@google.com Alex Amato
              Reporter:
              thw Thomas Weise
            • Votes:
              0 Vote for this issue
              Watchers:
              7 Start watching this issue

              Dates

              • Created:
                Updated: