samza-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Xinyu Liu (JIRA)" <j...@apache.org>
Subject [jira] [Created] (SAMZA-1567) Allow user WatermarkFunction to exclude streams from Watermark computation
Date Wed, 24 Jan 2018 22:35:00 GMT
Xinyu Liu created SAMZA-1567:
--------------------------------

             Summary: Allow user WatermarkFunction to exclude streams from Watermark computation
                 Key: SAMZA-1567
                 URL: https://issues.apache.org/jira/browse/SAMZA-1567
             Project: Samza
          Issue Type: Bug
    Affects Versions: 0.15.0
            Reporter: Xinyu Liu
            Assignee: Xinyu Liu
             Fix For: 0.15.0


Current watermark logic calculates the watermark based on the watermark all the upstream operators.
BEAM has a very special use case that requires excluding certain streams from this calcuation
(view streams), and the watermark from these streams should be directly passed down to the
WatermarkFunction.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message