Abacn commented on issue #32021:
URL: https://github.com/apache/beam/issues/32021#issuecomment-2258740204
By saying unsupported, the following log is seen:
Direct runner:
```
[Test worker] ERROR org.apache.beam.sdk.metrics.MetricsEnvironment - Unable
to update metrics on the current thread. Most likely caused by using metrics
outside the managed work-execution thread:
java.lang.Thread.getStackTrace(Thread.java:1564)
org.apache.beam.sdk.metrics.MetricsEnvironment.getCurrentContainer(MetricsEnvironment.java:140)
org.apache.beam.sdk.metrics.DelegatingCounter.inc(DelegatingCounter.java:76)
org.apache.beam.sdk.metrics.DelegatingCounter.inc(DelegatingCounter.java:67)
org.apache.beam.sdk.metrics.MetricsTest$CountingSourceWithMetrics.split(MetricsTest.java:495)
org.apache.beam.runners.direct.BoundedReadEvaluatorFactory$InputProvider.getInitialInputs(BoundedReadEvaluatorFactory.java:217)
org.apache.beam.runners.direct.ReadEvaluatorFactory$InputProvider.getInitialInputs(ReadEvaluatorFactory.java:88)
org.apache.beam.runners.direct.RootProviderRegistry.getInitialInputs(RootProviderRegistry.java:80)
org.apache.beam.runners.direct.ExecutorServiceParallelExecutor.start(ExecutorServiceParallelExecutor.java:161)
org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:213)
...
```
Flink runner:
```
```
This is different from a log ususally seen when reporting metrics in a
callback thread
https://github.com/apache/beam/blob/89d5e2f29615c1d4dba41c42a2161d5c5d5f39a8/sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsEnvironment.java#L144
here Java core's `isMetricsSupported()` returns true, but not actually
supported by the runner. So this is a feature gap rather than WAI by spec
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
