You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@samza.apache.org by navina <gi...@git.apache.org> on 2017/01/24 19:49:12 UTC

[GitHub] samza pull request #44: Initial Standalone JobCoordinator and StreamProcesso...

GitHub user navina opened a pull request:

    https://github.com/apache/samza/pull/44

    Initial Standalone JobCoordinator and StreamProcessor API

    This patch contains changes associated with the Standalone StreamProcessor, where there is no coordination. This will work for load-balanced consumers like new Kafka consumer and statically partitioned cases. 
    
    Additionally, we have introduced TaskFactory for StreamTask and AsyncStreamTask. 

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/navina/samza Noop-JC

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/samza/pull/44.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 #44
    
----
commit 76b5167e856984d627a73f020d4ca1c7e9ae8750
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date:   2017-01-23T21:16:49Z

    added new line at then end

commit 47bf91f8676e26c0de531019e21b6660d744e13f
Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
Date:   2017-01-06T20:22:16Z

    SAMZA-1076; getKafkaChangelogEnabledStores() should use StorageConfig.getChangelo\u2026
    
    getKafkaChangelogEnabledStores() should use StorageConfig.getChangelogStream to get changelog system.stream
    
    Author: Boris Shkolnik <bs...@bshkolni-ld1.linkedin.biz>
    
    Reviewers: xiliu <xi...@linkedin.com>
    
    Closes #39 from sborya/KafkConfigForChangelogStream

commit 0dda667b536b14ab12339fc7780db8a7a28bded4
Author: Xinyu Liu <xi...@xiliu-ld.linkedin.biz>
Date:   2017-01-11T18:42:26Z

    SAMZA-1078: Add my gpg key to KEYS
    
    Author: Xinyu Liu <xi...@xiliu-ld.linkedin.biz>
    
    Closes #41 from xinyuiscool/KEYS

commit 0fc1b4d176c5c62012e32c745d46dc8315a96e3b
Author: navina <na...@apache.org>
Date:   2017-01-24T19:04:20Z

    Adding StreamProcessor and JobCoordinator API along with TaskFactories

commit 70aa08d66d1a1555da69f2607c965d1bc5be0289
Author: navina <na...@apache.org>
Date:   2017-01-24T19:45:30Z

    Removing SimpleGroupByContainer and SimpleGroupByContainerFactory

----


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] samza pull request #44: SAMZA-1080 : Initial Standalone JobCoordinator and S...

Posted by asfgit <gi...@git.apache.org>.

Github user asfgit closed the pull request at:

    https://github.com/apache/samza/pull/44


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---