You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@samza.apache.org by rmatharu <gi...@git.apache.org> on 2019/01/13 04:09:59 UTC
[GitHub] samza pull request #876: Basic Standby container implementation
GitHub user rmatharu opened a pull request:
https://github.com/apache/samza/pull/876
Basic Standby container implementation
Please DO Not review yet.
This is to be rebased on top of PR 871 and 872.
This PR brings a basic standby container implementation, that uses Standby tasks using
SideInputs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmatharu/samza test-basicStandby
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/876.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 #876
----
commit b42e65c4b1bc98c364abc95a8226e4215ad6f388
Author: Ray Matharu <rm...@...>
Date: 2019-01-04T19:04:30Z
Adding basic standby generator
commit 4ef378da7d4123b00e8df54d437d40caa31ed3a0
Author: Ray Matharu <rm...@...>
Date: 2019-01-05T01:36:21Z
Adding standbytaskgenerator that uses prefixed tasknames, and suffixed container ids
commit b68312fc2fd7ca461c8e06153c78e90e9d6f4260
Author: Ray Matharu <rm...@...>
Date: 2019-01-05T02:11:22Z
Adding config for replication-factor and renaming configs to task-replication-factor
commit 9cc0e0db0fbddf32f7944bda80188e5c4780c998
Author: Ray Matharu <rm...@...>
Date: 2019-01-05T06:15:23Z
minor
commit be03b7f497186833b015cb1e2aff91285d321b68
Author: Ray Matharu <rm...@...>
Date: 2019-01-07T21:57:04Z
Minor
commit df4083cad1911c5a1a6adc04aaeb2851182b4662
Author: Ray Matharu <rm...@...>
Date: 2019-01-08T01:51:22Z
Adding TaskMode and its assignment to active
commit ca2e82f65f68f25d9fe1c3119f06b51247313d55
Author: Ray Matharu <rm...@...>
Date: 2019-01-08T23:23:15Z
Adding documentation, comments
commit d00b05ca6b569e082d4820defa379fcd40eeddb0
Author: Ray Matharu <rm...@...>
Date: 2019-01-08T23:28:15Z
minor
commit a6c8c1852dd895788703cdac7c79fcfdb3deac4a
Author: Ray Matharu <rm...@...>
Date: 2019-01-09T00:15:40Z
Adding comments and documentation
commit bd674aa8283dcc4dde0f421be789fb44199c5ce0
Author: Ray Matharu <rm...@...>
Date: 2019-01-09T01:21:54Z
Adding test for standbytask generator
commit f129e98bdc0f6aa872c29cd0c0049ecfa9a7e9df
Author: Ray Matharu <rm...@...>
Date: 2019-01-09T06:25:08Z
Minor
commit 197893a5adf299b19f0729f9516bec73cea6cf42
Author: Ray Matharu <rm...@...>
Date: 2019-01-09T06:27:34Z
ENsure test passes
commit 343540fe184f38c4b9fedc0ed59dc46264eccb6a
Author: Ray Matharu <rm...@...>
Date: 2019-01-09T06:29:52Z
Merge branch 'standbygenerator' into test-basicStandby
commit 90ad3b91eb48cec51f27275960a252874e798503
Author: Ray Matharu <rm...@...>
Date: 2019-01-09T06:45:12Z
Using standbytaskgenerator with taskmode
commit a1d2befef9bd1caf67fc629cee2993ee5eb27193
Author: Ray Matharu <rm...@...>
Date: 2019-01-11T21:48:19Z
testing basic standby
commit 7db79dcfb49fbaf9e31fa0ccf77448d1e7e30f33
Author: Ray Matharu <rm...@...>
Date: 2019-01-11T22:42:49Z
basic
commit a305cfb9edd0d9dc41d31830f616c091765587d5
Author: Ray Matharu <rm...@...>
Date: 2019-01-11T23:04:08Z
add serde
commit 20e611cfa43d02bd3515847b2ff577d4a440122f
Author: Ray Matharu <rm...@...>
Date: 2019-01-12T01:44:39Z
Basic standby setup with byteserde
commit f679b9d8bc3751fade289572a47144bf5dbe4be7
Author: Ray Matharu <rm...@...>
Date: 2019-01-12T05:45:34Z
Minor
commit 78c2493fc811eb469d4f9e063238c06a5ce0bc2f
Author: Ray Matharu <rm...@...>
Date: 2019-01-12T05:59:23Z
Merge branch 'master' into test-basicStandby
commit 3288cb83347a8267a0d4f9a0c9618dd0ee8178cd
Author: Ray Matharu <rm...@...>
Date: 2019-01-12T08:09:22Z
Making it work with latest CSM
commit 73c9b325fbafbf4eafbe1a911d4bd71ed3f6f437
Author: Ray Matharu <rm...@...>
Date: 2019-01-12T08:39:10Z
minor. removing TSM creation for standby tasks
commit d263040adb00c85a817439b3d6bae651f739eff3
Author: Ray Matharu <rm...@...>
Date: 2019-01-13T04:07:23Z
Adding debug log
----
---