Aditya Guru created BEAM-6739:
---------------------------------
Summary: Deafult withAllowedLateness() for triggering when not
using GlobalWindows
Key: BEAM-6739
URL: https://issues.apache.org/jira/browse/BEAM-6739
Project: Beam
Issue Type: Improvement
Components: sdk-java-core
Reporter: Aditya Guru
ERROR:
Exception in thread "main" java.lang.IllegalArgumentException: Except when
using GlobalWindows, calling .triggering() to specify a trigger requires that
the allowed lateness be specified using .withAllowedLateness() to set the upper
bound on how late data can arrive before being dropped.
I guess it would be good to have a default behavior for such cases. I would
suggest withAllowedLateness(Duration.ZERO)
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)