flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3647) Change StreamSource to use Processing-Time Clock Service
Date Tue, 22 Mar 2016 11:06:25 GMT
Aljoscha Krettek created FLINK-3647:
---------------------------------------

             Summary: Change StreamSource to use Processing-Time Clock Service
                 Key: FLINK-3647
                 URL: https://issues.apache.org/jira/browse/FLINK-3647
             Project: Flink
          Issue Type: Sub-task
            Reporter: Aljoscha Krettek


Currently, the {{StreamSource.AutomaticWatermarkContext}} has it's own timer service. This
should be changed to use the Clock service introduced in FLINK-XXXX to make watermark emission
testable by providing a custom Clock.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message