[jira] [Updated] (SAMZA-1109) Creating Serde regristry to support typed data serdes in samza-api

[ https://issues.apache.org/jira/browse/SAMZA-1109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1109: -- Fix Version/s: (was: 0.13.0) 0.14.0 > Creating Serde regristry

[jira] [Assigned] (SAMZA-1179) Documentation of ApplicationRunner

[ https://issues.apache.org/jira/browse/SAMZA-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari reassigned SAMZA-1179: - Assignee: Xinyu Liu > Documentation of ApplicationRunner >

[jira] [Updated] (SAMZA-1168) Migrate yarn local runner to use StreamProcessor

[ https://issues.apache.org/jira/browse/SAMZA-1168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1168: -- Fix Version/s: (was: 0.13.0) 0.14.0 > Migrate yarn local runner

[jira] [Updated] (SAMZA-1133) TestApplicationRunner for executing Samza StreamApplication in testing environment

[ https://issues.apache.org/jira/browse/SAMZA-1133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1133: -- Fix Version/s: (was: 0.13.0) 0.14.0 > TestApplicationRunner for

[jira] [Created] (SAMZA-1218) Support taskFactory in local application runner.

Xinyu Liu created SAMZA-1218: Summary: Support taskFactory in local application runner. Key: SAMZA-1218 URL: https://issues.apache.org/jira/browse/SAMZA-1218 Project: Samza Issue Type: Bug

[jira] [Updated] (SAMZA-1218) Support taskFactory in local application runner.

[ https://issues.apache.org/jira/browse/SAMZA-1218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1218: - Fix Version/s: 0.13.0 > Support taskFactory in local application runner. >

[jira] [Updated] (SAMZA-1152) List integration tests needed for the StandAlone project

[ https://issues.apache.org/jira/browse/SAMZA-1152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1152: -- Summary: List integration tests needed for the StandAlone project (was: [DISCUSS] List

[jira] [Created] (SAMZA-1221) Simplify MessageStreamImpl and OperatorSpec graphs and traversals

Prateek Maheshwari created SAMZA-1221: - Summary: Simplify MessageStreamImpl and OperatorSpec graphs and traversals Key: SAMZA-1221 URL: https://issues.apache.org/jira/browse/SAMZA-1221 Project:

[jira] [Resolved] (SAMZA-1213) StreamProcessorLifeCycleAware interface should not use processorId

[ https://issues.apache.org/jira/browse/SAMZA-1213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navina Ramesh resolved SAMZA-1213. -- Resolution: Fixed Issue resolved by pull request 125 [https://github.com/apache/samza/pull/125]

[jira] [Commented] (SAMZA-1213) StreamProcessorLifeCycleAware interface should not use processorId

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

[jira] [Commented] (SAMZA-1174) Profiling State Perfromance

[ https://issues.apache.org/jira/browse/SAMZA-1174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15975454#comment-15975454 ] ASF GitHub Bot commented on SAMZA-1174: --- GitHub user s-noghabi opened a pull request:

[jira] [Updated] (SAMZA-1220) Add thread name to SamzaContainer shutdown hook and prevent shutdown deadlock

[ https://issues.apache.org/jira/browse/SAMZA-1220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1220: -- Summary: Add thread name to SamzaContainer shutdown hook and prevent shutdown deadlock

[jira] [Created] (SAMZA-1220) Add thread name to SamzaContainer shutdown hook and prevent

Prateek Maheshwari created SAMZA-1220: - Summary: Add thread name to SamzaContainer shutdown hook and prevent Key: SAMZA-1220 URL: https://issues.apache.org/jira/browse/SAMZA-1220 Project: Samza

[jira] [Commented] (SAMZA-1221) Simplify MessageStreamImpl and OperatorSpec graphs and traversals

[ https://issues.apache.org/jira/browse/SAMZA-1221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15975357#comment-15975357 ] Prateek Maheshwari commented on SAMZA-1221: --- [~jagadish1...@gmail.com] thanks for the

samza git commit: SAMZA-1213 - StreamProcessorLifeCycleAware interface should not use processorId

Repository: samza Updated Branches: refs/heads/master 1f3db9cc6 -> 2a92980de SAMZA-1213 - StreamProcessorLifeCycleAware interface should not use processorId Refactoring LocalApplicationRunner s.t. each processor has its own listener instance, instead of a single listener keeping track of all

[jira] [Created] (SAMZA-1219) Add metrics for operator message received and execution times

Prateek Maheshwari created SAMZA-1219: - Summary: Add metrics for operator message received and execution times Key: SAMZA-1219 URL: https://issues.apache.org/jira/browse/SAMZA-1219 Project: Samza

[jira] [Resolved] (SAMZA-1148) Wire up fluent API input/output stream serdes

[ https://issues.apache.org/jira/browse/SAMZA-1148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1148. --- Resolution: Duplicate Fix Version/s: (was: 0.13.0) > Wire up fluent API

[jira] [Created] (SAMZA-1222) Clean up LocalApplicationRunner

Xinyu Liu created SAMZA-1222: Summary: Clean up LocalApplicationRunner Key: SAMZA-1222 URL: https://issues.apache.org/jira/browse/SAMZA-1222 Project: Samza Issue Type: Bug Affects Versions:

[jira] [Updated] (SAMZA-1204) Visualize StreamGraph and ExecutionPlan

[ https://issues.apache.org/jira/browse/SAMZA-1204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1204: - Attachment: dag2.png dag1.png > Visualize StreamGraph and ExecutionPlan >

[jira] [Updated] (SAMZA-1204) Visualize StreamGraph and ExecutionPlan

[ https://issues.apache.org/jira/browse/SAMZA-1204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1204: - Description: Based on SAMZA-1178, we are able to generate the JSON representation of StreamGraph and

[jira] [Created] (SAMZA-1225) Add demo examples for programming with the fluent API

Jagadish created SAMZA-1225: --- Summary: Add demo examples for programming with the fluent API Key: SAMZA-1225 URL: https://issues.apache.org/jira/browse/SAMZA-1225 Project: Samza Issue Type: Bug

[jira] [Commented] (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:comment-tabpanel=15974507#comment-15974507 ] ASF GitHub Bot commented on SAMZA-1136: --- Github user logarithm closed the pull request at:

[jira] [Commented] (SAMZA-1176) Intermittent TestJoinOperator unit test failure

[ https://issues.apache.org/jira/browse/SAMZA-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974209#comment-15974209 ] ASF GitHub Bot commented on SAMZA-1176: --- GitHub user prateekm opened a pull request:

[jira] [Updated] (SAMZA-1176) Intermittent TestJoinOperator unit test failure

[ https://issues.apache.org/jira/browse/SAMZA-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1176: -- Summary: Intermittent TestJoinOperator unit test failure (was: Make TestJoinOperator

samza git commit: SAMZA-1209; Improve error handling in LocalStoreMonitor

Repository: samza Updated Branches: refs/heads/master d50b1791b -> 1f3db9cc6 SAMZA-1209; Improve error handling in LocalStoreMonitor Changes: 1. Add opt-in configuration to continue garbage collection of local stores when there’s a failure in garbage collecting one local store. 2.