[ 
https://issues.apache.org/jira/browse/SAMZA-1657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jon Bringhurst updated SAMZA-1657:
----------------------------------
    Description: 
From: 
[https://samza.apache.org/learn/documentation/latest/jobs/configuration-table.html]

{noformat}task.window.ms -1 If task.class implements WindowableTask, it can 
receive a windowing callback in regular intervals. This property specifies the 
time between window() calls, in milliseconds. If the number is negative (the 
default), window() is never called. Note that Samza is single-threaded, so a 
window() call will never occur concurrently with the processing of a message. 
If a message is being processed at the time when a window() call is due, the 
window() call occurs after the processing of the current message has 
completed.{noformat}

This should be updated to remove the following statement:

{noformat}Samza is single-threaded{noformat}

  was:
From: 
https://samza.apache.org/learn/documentation/latest/jobs/configuration-table.html

{noformat}task.window.ms -1 If task.class implements WindowableTask, it can 
receive a windowing callback in regular intervals. This property specifies the 
time between window() calls, in milliseconds. If the number is negative (the 
default), window() is never called. Note that Samza is single-threaded, so a 
window() call will never occur concurrently with the processing of a message. 
If a message is being processed at the time when a window() call is due, the 
window() call occurs after the processing of the current message has 
completed.\{noformat}

This should be updated to remove the following statement:

{noformat}Samza is single-threaded\{noformat}


> Docs for task.window.ms are outdated
> ------------------------------------
>
>                 Key: SAMZA-1657
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1657
>             Project: Samza
>          Issue Type: Bug
>            Reporter: Jon Bringhurst
>            Priority: Major
>
> From: 
> [https://samza.apache.org/learn/documentation/latest/jobs/configuration-table.html]
> {noformat}task.window.ms -1 If task.class implements WindowableTask, it can 
> receive a windowing callback in regular intervals. This property specifies 
> the time between window() calls, in milliseconds. If the number is negative 
> (the default), window() is never called. Note that Samza is single-threaded, 
> so a window() call will never occur concurrently with the processing of a 
> message. If a message is being processed at the time when a window() call is 
> due, the window() call occurs after the processing of the current message has 
> completed.{noformat}
> This should be updated to remove the following statement:
> {noformat}Samza is single-threaded{noformat}



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

Reply via email to