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 <rmatharu@...> Date: 2019-01-04T19:04:30Z Adding basic standby generator commit 4ef378da7d4123b00e8df54d437d40caa31ed3a0 Author: Ray Matharu <rmatharu@...> Date: 2019-01-05T01:36:21Z Adding standbytaskgenerator that uses prefixed tasknames, and suffixed container ids commit b68312fc2fd7ca461c8e06153c78e90e9d6f4260 Author: Ray Matharu <rmatharu@...> Date: 2019-01-05T02:11:22Z Adding config for replication-factor and renaming configs to task-replication-factor commit 9cc0e0db0fbddf32f7944bda80188e5c4780c998 Author: Ray Matharu <rmatharu@...> Date: 2019-01-05T06:15:23Z minor commit be03b7f497186833b015cb1e2aff91285d321b68 Author: Ray Matharu <rmatharu@...> Date: 2019-01-07T21:57:04Z Minor commit df4083cad1911c5a1a6adc04aaeb2851182b4662 Author: Ray Matharu <rmatharu@...> Date: 2019-01-08T01:51:22Z Adding TaskMode and its assignment to active commit ca2e82f65f68f25d9fe1c3119f06b51247313d55 Author: Ray Matharu <rmatharu@...> Date: 2019-01-08T23:23:15Z Adding documentation, comments commit d00b05ca6b569e082d4820defa379fcd40eeddb0 Author: Ray Matharu <rmatharu@...> Date: 2019-01-08T23:28:15Z minor commit a6c8c1852dd895788703cdac7c79fcfdb3deac4a Author: Ray Matharu <rmatharu@...> Date: 2019-01-09T00:15:40Z Adding comments and documentation commit bd674aa8283dcc4dde0f421be789fb44199c5ce0 Author: Ray Matharu <rmatharu@...> Date: 2019-01-09T01:21:54Z Adding test for standbytask generator commit f129e98bdc0f6aa872c29cd0c0049ecfa9a7e9df Author: Ray Matharu <rmatharu@...> Date: 2019-01-09T06:25:08Z Minor commit 197893a5adf299b19f0729f9516bec73cea6cf42 Author: Ray Matharu <rmatharu@...> Date: 2019-01-09T06:27:34Z ENsure test passes commit 343540fe184f38c4b9fedc0ed59dc46264eccb6a Author: Ray Matharu <rmatharu@...> Date: 2019-01-09T06:29:52Z Merge branch 'standbygenerator' into test-basicStandby commit 90ad3b91eb48cec51f27275960a252874e798503 Author: Ray Matharu <rmatharu@...> Date: 2019-01-09T06:45:12Z Using standbytaskgenerator with taskmode commit a1d2befef9bd1caf67fc629cee2993ee5eb27193 Author: Ray Matharu <rmatharu@...> Date: 2019-01-11T21:48:19Z testing basic standby commit 7db79dcfb49fbaf9e31fa0ccf77448d1e7e30f33 Author: Ray Matharu <rmatharu@...> Date: 2019-01-11T22:42:49Z basic commit a305cfb9edd0d9dc41d31830f616c091765587d5 Author: Ray Matharu <rmatharu@...> Date: 2019-01-11T23:04:08Z add serde commit 20e611cfa43d02bd3515847b2ff577d4a440122f Author: Ray Matharu <rmatharu@...> Date: 2019-01-12T01:44:39Z Basic standby setup with byteserde commit f679b9d8bc3751fade289572a47144bf5dbe4be7 Author: Ray Matharu <rmatharu@...> Date: 2019-01-12T05:45:34Z Minor commit 78c2493fc811eb469d4f9e063238c06a5ce0bc2f Author: Ray Matharu <rmatharu@...> Date: 2019-01-12T05:59:23Z Merge branch 'master' into test-basicStandby commit 3288cb83347a8267a0d4f9a0c9618dd0ee8178cd Author: Ray Matharu <rmatharu@...> Date: 2019-01-12T08:09:22Z Making it work with latest CSM commit 73c9b325fbafbf4eafbe1a911d4bd71ed3f6f437 Author: Ray Matharu <rmatharu@...> Date: 2019-01-12T08:39:10Z minor. removing TSM creation for standby tasks commit d263040adb00c85a817439b3d6bae651f739eff3 Author: Ray Matharu <rmatharu@...> Date: 2019-01-13T04:07:23Z Adding debug log ---- ---