[GitHub] [ignite-3] ibessonov commented on a diff in pull request #1490: IGNITE-18397 Rework Watches based on Raft Learners

2023-01-20 Thread GitBox
ibessonov commented on code in PR #1490: URL: https://github.com/apache/ignite-3/pull/1490#discussion_r1082586412 ## modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/server/raft/MetaStorageLearnerListener.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to the

[GitHub] [ignite-3] ibessonov commented on a diff in pull request #1490: IGNITE-18397 Rework Watches based on Raft Learners

2023-01-20 Thread GitBox
ibessonov commented on code in PR #1490: URL: https://github.com/apache/ignite-3/pull/1490#discussion_r1082584043 ## modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/impl/MetaStorageManagerImpl.java: ## @@ -842,11 +753,9 @@ public boolean hasNext() {

[GitHub] [ignite-3] ibessonov commented on a diff in pull request #1490: IGNITE-18397 Rework Watches based on Raft Learners

2023-01-20 Thread GitBox
ibessonov commented on code in PR #1490: URL: https://github.com/apache/ignite-3/pull/1490#discussion_r1082584043 ## modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/impl/MetaStorageManagerImpl.java: ## @@ -842,11 +753,9 @@ public boolean hasNext() {

[GitHub] [ignite-3] ibessonov commented on a diff in pull request #1490: IGNITE-18397 Rework Watches based on Raft Learners

2023-01-20 Thread GitBox
ibessonov commented on code in PR #1490: URL: https://github.com/apache/ignite-3/pull/1490#discussion_r1082582875 ## modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/DistributionZoneManager.java: ## @@ -741,39 +742,27 @@ private void initData

[GitHub] [ignite-3] ibessonov commented on a diff in pull request #1490: IGNITE-18397 Rework Watches based on Raft Learners

2023-01-20 Thread GitBox
ibessonov commented on code in PR #1490: URL: https://github.com/apache/ignite-3/pull/1490#discussion_r1080883366 ## modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/DistributionZoneManager.java: ## @@ -741,39 +742,27 @@ private void initData