[
https://issues.apache.org/jira/browse/SAMZA-1155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996006#comment-15996006
]
ASF GitHub Bot commented on SAMZA-1155:
---------------------------------------
GitHub user vjagadish1989 opened a pull request:
https://github.com/apache/samza/pull/160
SAMZA-1155: Validate users configure window.ms when using the fluent API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vjagadish1989/samza samza-1155
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/160.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #160
----
commit a48709edb4e4da4ce362b174e84cf6df9b581585
Author: vjagadish1989 <[email protected]>
Date: 2017-05-01T15:09:45Z
SAMZA-1249: Fix equality for WindowKey for Non-keyed tumbling windows
commit 6c3d0dc166a6bfd0aea099ffcdc88789cbacbf97
Author: vjagadish1989 <[email protected]>
Date: 2017-05-03T02:19:14Z
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/samza
commit b3ec772421141bb77ad611eb25ff714e69f777b2
Author: vjagadish1989 <[email protected]>
Date: 2017-05-04T01:04:44Z
SAMZA-1155: Validate users configure window.ms when using the fluent API
----
> Allow configuring window.ms to specify trigger duration
> -------------------------------------------------------
>
> Key: SAMZA-1155
> URL: https://issues.apache.org/jira/browse/SAMZA-1155
> Project: Samza
> Issue Type: Bug
> Reporter: Jagadish
> Assignee: Jagadish
> Fix For: 0.13.0
>
>
> When a user writes a `StreamTask` (low level API), the property
> `task.window.ms` specifies the interval for windowing in Samza. However, when
> a user writes a `StreamApplication` (higher level API), we should
> automatically set `task.window.ms` to a default value (say, 1 minute). The
> value of `task.window.ms` will be used to evaluate (and potentially fire)
> time-based Triggers configured for the application.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
