GitHub user navina opened a pull request:
https://github.com/apache/samza/pull/103
SAMZA-1126 - Semantics of processorId in Samza
Implementation based on
[SEP-1](https://cwiki.apache.org/confluence/display/SAMZA/SEP-1%3A+Semantics+of+ProcessorId+in+Samza)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/navina/samza SAMZA-1126
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/103.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 #103
----
commit b0b31979ab5da4d83878152058f446c42dbce82f
Author: navina <[email protected]>
Date: 2017-03-29T22:09:05Z
Removing CoordinationService from JobCoordinatorFactory interface
commit d7e649368b9b05ad307368581fc28d396289bfb7
Author: navina <[email protected]>
Date: 2017-03-23T21:22:58Z
Added ProcessorIdGenerator. StreamProcessor tests fail due to containerId
type mismatch in Containermodel
commit edfac1163cdf7191d83feaf3c11bc27dfd41d3c2
Author: navina <[email protected]>
Date: 2017-03-24T18:41:11Z
First pass at changing to string; ContainerModel has both processorId and
containerId
commit 94e000127d79a7106bcd3e9c7d9363f0596a3c16
Author: navina <[email protected]>
Date: 2017-03-24T20:49:49Z
Added jobmodel deserialization for compatibility between old and new models
commit 9290483466f4504306201d78522de23a03753855
Author: navina <[email protected]>
Date: 2017-03-24T21:21:49Z
Adding custom deserializer for ContainerModel
commit fea84abe7707f93af0a133d7d30be7dfa4311911
Author: navina <[email protected]>
Date: 2017-03-24T23:50:12Z
updating code in TestSamzaContainer.scala
commit f8b85a52731039996cf9357c7c85adc36e98ae5a
Author: navina <[email protected]>
Date: 2017-03-25T01:57:30Z
Mostly builds. TaskProxy stuff needs to be fixed
commit 17d905ff920c70e4c95d5fd3b5c23ff94c549f25
Author: navina <[email protected]>
Date: 2017-03-27T21:26:06Z
Removed static method from ProcessorIdGenerator and made it a ClassLoader
util
commit da4566201b834da8aa1dcead594ace3a98332132
Author: navina <[email protected]>
Date: 2017-03-28T18:15:46Z
Changing containerId to string in YarnClusterResourceManager state
commit 987f2ffdb1c581eadc7907fd1050a36d9dacd7cc
Author: navina <[email protected]>
Date: 2017-03-28T18:29:27Z
Fixing some documents
commit 96a104394add60bea554ce6766a4ec2459c8745a
Author: navina <[email protected]>
Date: 2017-03-29T21:23:11Z
Fixed breaking changes after rebase
commit 8d32878d5d29b39c4a5363f9407ef1473efa3fd4
Author: navina <[email protected]>
Date: 2017-03-30T01:06:29Z
Commenting a flaky test and rebasing
----
---
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 [email protected] or file a JIRA ticket
with INFRA.
---