Re: Beam Metrics not shown in Flink Web UI

I figured out from docs/code that Beam Metrics support is not present for Flink runner in detached mode of pipeline execution. Is there any way around it? On Wed, Jun 13, 2018 at 5:27 PM, Abdul Qadeer wrote: > Not sure if inline image is visible, here is a > link. > > On

Re: Apache Beam June Newsletter

Thanks Gris, this is very cool ! besides we did not include schedule talks for the ApacheCon (end of September) because they 'll take place in a long time, maybe they'll be announced in the next news letter? Etienne Le mercredi 13 juin 2018 à 16:41 -0700, Pablo Estrada a écrit : > Thanks Gris!

RE: kafkaIO Run with Spark Runner: "streaming-job-executor-0"

Hi all, I have changed these versions of tools, as: Beam 2.4.0 (Spark runner with Standalone mode) Spark 2.0.0 Kafka: 2.11-0.10.1.1 Pom.xml: org.apache.beam beam-sdks-java-core 2.4.0 org.apache.beam beam-runners-spark 2.4.0 org.apache.beam beam-sdks-java-io-kafka