Wenzhe Zhou has uploaded a new patch set (#2). ( 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 fix. Made a small 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/2 -- 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: newpatchset Gerrit-Change-Id: I21c1e6f6d8b047a37c7db2b7995b7ff74e317226 Gerrit-Change-Number: 20247 Gerrit-PatchSet: 2 Gerrit-Owner: Wenzhe Zhou <[email protected]> Gerrit-Reviewer: Abhishek Rawat <[email protected]> Gerrit-Reviewer: Andrew Sherman <[email protected]> Gerrit-Reviewer: Impala Public Jenkins <[email protected]>
