[jira] [Commented] (SAMZA-1103) Barrier for job model update

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

[jira] [Resolved] (SAMZA-1102) ZkController for communication with the ZK

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

[jira] [Commented] (SAMZA-1102) ZkController for communication with the ZK

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

samza git commit: SAMZA-1102: Zk controller

Repository: samza Updated Branches: refs/heads/master e6147fdac -> f1bc1d0b3 SAMZA-1102: Zk controller SAMZA-1102: Added ZKController and ZkControllerImpl Author: Boris Shkolnik Author: navina Reviewers: Navina Ramesh

[jira] [Commented] (SAMZA-1092) Updated fluent API to use the refactored StreamSpec class

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

samza git commit: SAMZA-1092: replace stream spec in fluent API

Repository: samza Updated Branches: refs/heads/master b5ea8776e -> e6147fdac SAMZA-1092: replace stream spec in fluent API Replaced the StreamSpec class w/ the new one from SAMZA-1075. Author: Yi Pan (Data Infrastructure) Reviewers: Jacob Maes

samza git commit: SAMZA-1096: Followup - Two more tests and remove a comment block that was missed

Repository: samza Updated Branches: refs/heads/samza-fluent-api-v1 03bacdc60 -> d39bce9cb SAMZA-1096: Followup - Two more tests and remove a comment block that was missed Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit:

[jira] [Created] (SAMZA-1102) ZkController for communication with the ZK

Boris Shkolnik created SAMZA-1102: - Summary: ZkController for communication with the ZK Key: SAMZA-1102 URL: https://issues.apache.org/jira/browse/SAMZA-1102 Project: Samza Issue Type:

[jira] [Updated] (SAMZA-1101) Delay the creation of actual function to send to a physical stream until OperatorImpl instantiation

[ https://issues.apache.org/jira/browse/SAMZA-1101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1101: Affects Version/s: 0.12.0 > Delay the creation of actual function

[jira] [Assigned] (SAMZA-1101) Delay the creation of actual function to send to a physical stream until OperatorImpl instantiation

[ https://issues.apache.org/jira/browse/SAMZA-1101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1101: --- Assignee: Yi Pan (Data Infrastructure) > Delay the creation

[jira] [Created] (SAMZA-1101) Delay the creation of actual function to send to a physical stream until OperatorImpl instantiation

Yi Pan (Data Infrastructure) created SAMZA-1101: --- Summary: Delay the creation of actual function to send to a physical stream until OperatorImpl instantiation Key: SAMZA-1101 URL:

[02/13] samza git commit: SAMZA-1073: moving all operator classes into samza-core

http://git-wip-us.apache.org/repos/asf/samza/blob/8515448a/samza-operator/src/test/java/org/apache/samza/operators/TestMessageStreamImplUtil.java -- diff --git

[04/13] samza git commit: SAMZA-1073: moving all operator classes into samza-core

http://git-wip-us.apache.org/repos/asf/samza/blob/8515448a/samza-core/src/test/java/org/apache/samza/operators/impl/TestOperatorImpls.java -- diff --git

[09/13] samza git commit: SAMZA-1075: fix partitionCount assertion from PR53

SAMZA-1075: fix partitionCount assertion from PR53 nickpan47 here's the fix for the issue you found in PR53 Author: Jacob Maes Reviewers: Yi Pan Closes #57 from jmakes/samza-1075-2 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit:

[10/13] samza git commit: SAMZA-1097: update master branch to use 0.13.0-SNAPSHOT version

SAMZA-1097: update master branch to use 0.13.0-SNAPSHOT version Author: Yi Pan (Data Infrastructure) Reviewers: jagadish Closes #59 from nickpan47/SAMZA-1097 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit:

[01/13] samza git commit: SAMZA-1086; New Grouper for ZK based standalone.

Repository: samza Updated Branches: refs/heads/samza-fluent-api-v1 ea37b7463 -> 03bacdc60 SAMZA-1086; New Grouper for ZK based standalone. SAMZA-1086. Create new grouper with support for arbitrary container ids. Add support for this list of container IDs in the JobModelManager. Author: Boris

[11/13] samza git commit: SAMZA-1099: Documentation updates for Samza 0.12 release (for master branch)

SAMZA-1099: Documentation updates for Samza 0.12 release (for master branch) Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/b5ea8776 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/b5ea8776 Diff:

[03/13] samza git commit: SAMZA-1073: moving all operator classes into samza-core

http://git-wip-us.apache.org/repos/asf/samza/blob/8515448a/samza-operator/src/main/java/org/apache/samza/operators/spec/PartialJoinOperatorSpec.java -- diff --git

[12/13] samza git commit: SAMZA-1096: StreamSpec constructors in the ExecutionEnvironments

SAMZA-1096: StreamSpec constructors in the ExecutionEnvironments Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/674e5231 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/674e5231 Diff:

[06/13] samza git commit: SAMZA-1073: moving all operator classes into samza-core

SAMZA-1073: moving all operator classes into samza-core Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/8515448a Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/8515448a Diff: