[jira] [Updated] (SAMZA-1155) Allow configuring window.ms to specify trigger duration

[ https://issues.apache.org/jira/browse/SAMZA-1155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1155: Description: When a user writes a `StreamTask` (low level API), the property `task.window.ms` specifies the

[jira] [Created] (SAMZA-1155) Allow configuring window.ms to specify trigger duration

Jagadish created SAMZA-1155: --- Summary: 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

[jira] [Resolved] (SAMZA-1093) Instantiate StreamOperatorTask in SamzaContainer

[ https://issues.apache.org/jira/browse/SAMZA-1093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1093. - Resolution: Fixed > Instantiate StreamOperatorTask in

[jira] [Commented] (SAMZA-1108) Implement core windowing and triggering logic

[ https://issues.apache.org/jira/browse/SAMZA-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15931901#comment-15931901 ] ASF GitHub Bot commented on SAMZA-1108: --- Github user asfgit closed the pull request at:

[2/2] samza git commit: SAMZA-1108: Implementation of Windows and various kinds of Triggers

SAMZA-1108: Implementation of Windows and various kinds of Triggers * Implemented various triggers and the orchestration logic of the window operator. * Implemented wire-up of window and the flow of messages through various trigger implementations. * Implementations for count, time,

[jira] [Assigned] (SAMZA-1138) Yarn capability check is broken

[ https://issues.apache.org/jira/browse/SAMZA-1138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1138: --- Assignee: Maksim Logvinenko > Yarn capability check is

[jira] [Assigned] (SAMZA-1135) Support Scala 2.12

[ https://issues.apache.org/jira/browse/SAMZA-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1135: --- Assignee: Maksim Logvinenko > Support Scala 2.12 >

[jira] [Assigned] (SAMZA-1136) If latest offset <= 0 then SystemStreamMetadata is incorrect

[ https://issues.apache.org/jira/browse/SAMZA-1136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1136: --- Assignee: Maksim Logvinenko > If latest offset <= 0 then

[jira] [Assigned] (SAMZA-1145) Provide Ability To Confgure The Default Number Of Changelog Replicas

[ https://issues.apache.org/jira/browse/SAMZA-1145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1145: --- Assignee: James Lent > Provide Ability To Confgure The