You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/12/01 00:51:00 UTC
[jira] [Commented] (BEAM-3153) Allow streaming processing time
domain timers in Beam Python DirectRunner
[ https://issues.apache.org/jira/browse/BEAM-3153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16273747#comment-16273747 ]
ASF GitHub Bot commented on BEAM-3153:
--------------------------------------
mariapython commented on issue #4148: [BEAM-3153] Add Python processing-time timers and clock injection
URL: https://github.com/apache/beam/pull/4148#issuecomment-348368769
retest this please
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
> Allow streaming processing time domain timers in Beam Python DirectRunner
> -------------------------------------------------------------------------
>
> Key: BEAM-3153
> URL: https://issues.apache.org/jira/browse/BEAM-3153
> Project: Beam
> Issue Type: Bug
> Components: sdk-py-core
> Reporter: Charles Chen
> Assignee: María GH
>
> Currently, streaming execution in the Python Beam DirectRunner only allows for watermark domain timers and does not allow for processing time timers. We should support processing time timers, along with a testing framework (potentially with a fake clock) that lets us test this behavior using the TestStream primitive.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)