Hi, Jan, Thanks for reporting this issue to us. Processing time triggers are supported in Samza Runner with version Beam 2.22.0 [1]. The exception message wasn't updated after we added the support of processing time. Apologize for the confusion here. Looks most of the exception messages have been fixed in the latest code.
>From reading the code, it seems we will only run into this exception if we somehow end up having TimeDomain as synchronized_processing_time [2]. Samza runner does not support this time domain. Are you aware that your code might use it somehow? If not, I can help debug further. We have other users who use processing time triggers for early triggering, and it was working fine. I will also take a look at 2.27.0. LinkedIn has been recently upgraded to 2.26.0, and we found a few issues. Previously we were using a version close to 2.24.0. Thanks, Xinyu [1]: https://github.com/apache/beam/blob/9b43fadb8bb6f4bcabc945fc299b378eb1d7d205/runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java#L347 [2] https://github.com/apache/beam/blob/055140203ce2df56ba903b05266466cf16562dde/sdks/java/core/src/main/java/org/apache/beam/sdk/state/TimeDomain.java#L49 On Sun, Feb 7, 2021 at 2:24 PM Jan Bensien <stu128...@mail.uni-kiel.de> 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.UnsupportedOperationException: class > org.apache.beam.runners.samza.SamzaRunner currently only supports event > time. > Looking at the capability matrix of > Beam(https://beam.apache.org/documentation/runners/capability-matrix/), > it looks like processing time should be supported. > I could not find a documentation, for the exact supported features for > the different runner versions. > I am using the version 2.22.0 for the Samza Runner but also tried 2.25.0 > and got the same error. When i tried to upgrade to 2.27.0 I got the > following error: java.lang.UnsupportedOperationException: > BundleFinalizer unsupported in Samza. This happens whenever i use > KafkaIO to read from Kafka. Even when i tried a Pipeline that did > nothing except reading from Kafka. > > The trigger that caused the exception is the following: . > triggering(Repeatedly.forever( > AfterProcessingTime.pastFirstElementInPane() > .plusDelayOf(Duration.standardSeconds(1)))) > .accumulatingFiredPanes()); > > Running the pipeline with the Direct Runner worked fine. Which version > is the latest stable version of the Samza Runner and does it support > processing time triggers? > > With many thanks, > > Jan
