GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/3528
Kafka-4763 (Used for triggering test only) This patch is used only for triggering test. No need for review. You can merge this pull request into a Git repository by running: $ git pull https://github.com/lindong28/kafka KAFKA-4763-test Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3528.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 #3528 ---- commit a7915c2d7b7b1a96ba78a4d814503356da5840e6 Author: Dong Lin <lindon...@gmail.com> Date: 2017-04-03T00:46:34Z KAFKA-4763; Handle disk failure for JBOD (KIP-112) commit 946ece0f2067c1a890d00714ac24f298d9dcc8b5 Author: Dong Lin <lindon...@gmail.com> Date: 2017-06-12T04:05:12Z Address comments commit f1e250b61a21ea74d895ff1c2d289a359c70f117 Author: Dong Lin <lindon...@gmail.com> Date: 2017-06-12T09:13:28Z StopReplicaResponse should specify error if replica-to-be-deleted is not found and there is offline directory commit 8f02b2b94a9acd016c7a88cb196f12abd3890960 Author: Dong Lin <lindon...@gmail.com> Date: 2017-06-13T20:15:58Z Address comments commit dc1d6f3c89595e6192833df3f780f9053bf9327e Author: Dong Lin <lindon...@gmail.com> Date: 2017-06-17T02:35:18Z Address comments commit 7c531a273deab40fe5952377a85baf6aae286760 Author: Dong Lin <lindon...@gmail.com> Date: 2017-06-20T23:17:14Z Address comments commit 8bc60ab337ac65bf787c1fd47c4a3b5a65599d2c Author: Dong Lin <lindon...@gmail.com> Date: 2017-06-21T20:27:09Z Close file handler of all files in the offline log directory so that the disk can be umounted commit 1f399a22c9af01e34c8cfa74aac413400f018ff0 Author: Dong Lin <lindon...@gmail.com> Date: 2017-06-23T00:41:21Z Address comments commit 633d4843fbcd6421d1bd488557f47c7edb8086d3 Author: Dong Lin <lindon...@gmail.com> Date: 2017-06-24T02:09:54Z Catch and handle more IOExceptions commit 5908e16c37846edc8870f3e0dc2e14634d5d0d24 Author: Dong Lin <lindon...@gmail.com> Date: 2017-06-28T00:31:34Z Address comments commit fa2edcac7217105706340d8594f409be1341c7b0 Author: Dong Lin <lindon...@gmail.com> Date: 2017-06-30T21:55:30Z Address comments commit d4a54dffd675fff9b7763ae4b4ffcc908c54f408 Author: Dong Lin <lindon...@gmail.com> Date: 2017-07-06T03:50:35Z Address comments commit b25a029970a8802d7fe50a69f23fc365ae146b7e Author: Dong Lin <lindon...@gmail.com> Date: 2017-07-06T19:04:03Z Replace _liveLogDirs.asScala.toSeq with _liveLogDirs.asScala.toArray to possibly reduce memory footprint commit 522eff8ef2ae1f4235338335a7ef8657efa0e877 Author: Dong Lin <lindon...@gmail.com> Date: 2017-07-07T02:45:14Z - Use LogDirFailureChannel to trigger handleLogDirFailure() - Remove the newly-added metrics on shutdown() commit 5bbb72ed3ca042aa731d756c03bd2e86a2ed5a42 Author: Dong Lin <lindon...@gmail.com> Date: 2017-07-07T22:06:47Z - Add UNKNOWN_RETRIABLE. - Convert KafkaStorageException to the error code of NotLeaderForPartitionException for existing versions of ProduceResponse and FetchResponse commit e4404382f94754fb49bea4912e684d7e98e2e20c Author: Dong Lin <lindon...@gmail.com> Date: 2017-07-13T18:21:29Z Always return KafkaStorageException for replicas in offline log directories ---- --- 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 infrastruct...@apache.org or file a JIRA ticket with INFRA. ---