Re: Samza Runner for Beam Processing Time support

On Sun, Feb 7, 2021 at 2:24 PM Jan Bensien wrote: Hello, I am currently trying to execute my Beam Pipelines using the Samza Runner. I am using processing time triggers for calculating early results for my larger windows. However i am getting the following error: java.lang.UnsupportedOperationE

Samza Runner for Beam Processing Time support

Hello, I am currently trying to execute my Beam Pipelines using the Samza Runner. I am using processing time triggers for calculating early results for my larger windows. However i am getting the following error: java.lang.UnsupportedOperationException: class org.apache.beam.runners.samza.Sam

Problem regarding the Monitoring of Samza Applications

Hello, I hope this is the right place to ask. I am having problems monitoring my Samza application. Using the JMX-Exporter I found that the groups: KafkaSystemConsumersMetrics, ZkJobCoordinatorMetrics and ZkUtilsMetrics are not emitted. I am using Samza 1.5.0 in combination with Beam 2.22.0 a