Wenzhe Zhou has uploaded this change for review. ( http://gerrit.cloudera.org:8080/20247
Change subject: IMPALA-12304: Fix the sequence number issue for update_catalogd RPC ...................................................................... IMPALA-12304: Fix the sequence number issue for update_catalogd RPC Subscriber will re-register to statestore when statestore is restarted. When the statestore is restarted, its sending sequence number for update_catalogd RPC is reset. The subscribers need to reset their last receiving sequence number of update_catalogd RPC when they successfully re-register with statestore. Otherwise, subscribers may miss some RPCs after statestore is restarted. Could find related error messages in catalogd log file when run test_catalogd_ha.py::TestCatalogdHA::test_restart_statestore. Verified that no such error messages in catalogd log after the fixing. Made a samll optimization for statestore not to wake up the thread for update_catalogd RPC if there is no change for elected active catalogd and there is no RPC failure in last round. Testing: - Passed the core test. Change-Id: I21c1e6f6d8b047a37c7db2b7995b7ff74e317226 --- M be/src/statestore/statestore-subscriber.cc M be/src/statestore/statestore.cc M tests/custom_cluster/test_catalogd_ha.py 3 files changed, 13 insertions(+), 1 deletion(-) git pull ssh://gerrit.cloudera.org:29418/Impala-ASF refs/changes/47/20247/1 -- To view, visit http://gerrit.cloudera.org:8080/20247 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-Project: Impala-ASF Gerrit-Branch: master Gerrit-MessageType: newchange Gerrit-Change-Id: I21c1e6f6d8b047a37c7db2b7995b7ff74e317226 Gerrit-Change-Number: 20247 Gerrit-PatchSet: 1 Gerrit-Owner: Wenzhe Zhou <wz...@cloudera.com> Gerrit-Reviewer: Abhishek Rawat <ara...@cloudera.com> Gerrit-Reviewer: Andrew Sherman <asher...@cloudera.com>
