GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/3713
MINOR: simplify state transition for Kafka Streams and stream threads
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka KMinor-set-state
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/3713.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 #3713
----
commit 4da235927f9eebf2442533b44bf017454d372747
Author: Damian Guy <[email protected]>
Date: 2017-08-14T17:23:53Z
perform state restoration in poll loop
commit a7d6f54079ce61ec75bebbae74a2fd55701e9d53
Author: Damian Guy <[email protected]>
Date: 2017-08-16T14:18:25Z
move commitAll out of StreamThread
commit b35f1c7688a88ddadbf8a3e94e6c6132a4b827de
Author: Damian Guy <[email protected]>
Date: 2017-08-16T14:29:29Z
add test for AssignedTasks#commit
commit 4e2bf7e0829db11d34e0e8d2df27e21813e3ddcd
Author: Damian Guy <[email protected]>
Date: 2017-08-16T16:31:08Z
move more task oriented code out of stream thread
commit e9dae9f386a6b2c415cd2ab16cb012a8884ef320
Author: Damian Guy <[email protected]>
Date: 2017-08-17T11:09:07Z
address some of guozhang's comments
commit 3dbed27e661562e1af78941903f3f443ff1785a2
Author: Damian Guy <[email protected]>
Date: 2017-08-17T13:44:42Z
move all metric calculations back to StreamThread
commit cd3c8a6876cd535da7e33758351094213860952a
Author: Damian Guy <[email protected]>
Date: 2017-08-17T13:56:37Z
move printing of active tasks into TaskManager
commit 42785e92cafb792e01cfb91673bb8011fbff4224
Author: Damian Guy <[email protected]>
Date: 2017-08-18T08:44:24Z
address comments
commit 61f984d625562407b1034e284a017c26d4407963
Author: Damian Guy <[email protected]>
Date: 2017-08-18T09:19:57Z
add state restore integration test
commit 34142cf5afbb0bc842f9cd870cb5494e4011d48f
Author: Damian Guy <[email protected]>
Date: 2017-08-18T13:22:35Z
fix checkstyle
commit ec177b0c4464830fd9838214852887849aa24b2e
Author: Damian Guy <[email protected]>
Date: 2017-08-18T08:10:50Z
Add MeteredWindowStore and refactor store hierarchy such that Metered is
always the outer store.
commit 72a510c2e56489d8a843110b9371210edadbdd89
Author: Damian Guy <[email protected]>
Date: 2017-08-18T16:58:40Z
address comments
commit 247f9ab5167bf751be03621facdcefdccf394eca
Author: Guozhang Wang <[email protected]>
Date: 2017-08-19T17:38:55Z
Merge branch 'kafka-5689' of https://github.com/dguy/kafka into
KMinor-set-state
commit a1858243b9e12085be98f95254bc727fe4b85a8f
Author: Guozhang Wang <[email protected]>
Date: 2017-08-19T17:44:25Z
collapse setState functions
commit 6d32a9f7300dd26a2f6cf484e53eabaeb047b5a7
Author: Guozhang Wang <[email protected]>
Date: 2017-08-21T05:18:47Z
cherry-pick state diagrams into trunk
commit f4c6fa81701f8a6714b9e0f604afa30cc5808b0b
Author: Guozhang Wang <[email protected]>
Date: 2017-08-21T17:22:45Z
minor fix
commit d488b9c35121d7b321937c2e5d9831491b2eb8a2
Author: Guozhang Wang <[email protected]>
Date: 2017-08-22T18:52:12Z
rebase from trunk
commit 1570586342afe62a4891ee319e8d4b5b22919bfb
Author: Guozhang Wang <[email protected]>
Date: 2017-08-22T19:30:32Z
minor fix on unit tests
commit a5703325d9b711eedf814d0c84c45d6fc6c82781
Author: Guozhang Wang <[email protected]>
Date: 2017-08-22T20:04:01Z
minor fix
commit fb5461fd16aa8ca4ca11689ea9f3d03cdc3d8479
Author: Guozhang Wang <[email protected]>
Date: 2017-08-22T20:25:58Z
add log4j entries
----
---
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.
---
