I ran the test locally. In my test environment 9 documents mismatched.
2020-07-20 14:43:02 | INFO | MainProcess | test_thread | [basetestcase.sleep] sleep for 30 secs. Waiting for handler code Function_335895254_test_rebalance_in_with_different_topologies to complete bucket operations... Current : 40311 Expected : 40320 ...
|
2020-07-20 14:43:32 | INFO | MainProcess | test_thread | [basetestcase.sleep] sleep for 30 secs. Waiting for handler code Function_335895254_test_rebalance_in_with_different_topologies to complete bucket operations... Current : 40311 Expected : 40320 ...
|
2020-07-20 14:44:02 | INFO | MainProcess | test_thread | [basetestcase.sleep] sleep for 30 secs. Waiting for handler code Function_335895254_test_rebalance_in_with_different_topologies to complete bucket operations... Current : 40311 Expected : 40320 ...
|
2020-07-20 14:44:32 | INFO | MainProcess | test_thread | [basetestcase.sleep] sleep for 30 secs. Waiting for handler code Function_335895254_test_rebalance_in_with_different_topologies to complete bucket operations... Current : 40311 Expected : 40320 ...
|
2020-07-20 14:45:02 | INFO | MainProcess | test_thread | [basetestcase.sleep] sleep for 30 secs. Waiting for handler code Function_335895254_test_rebalance_in_with_different_topologies to complete bucket operations... Current : 40311 Expected : 40320 ...
|
2020-07-20 14:45:32 | INFO | MainProcess | test_thread | [basetestcase.sleep] sleep for 30 secs. Waiting for handler code Function_335895254_test_rebalance_in_with_different_topologies to complete bucket operations... Current : 40311 Expected : 40320 ...
|
2020-07-20 14:46:02 | INFO | MainProcess | test_thread | [basetestcase.sleep] sleep for 30 secs. Waiting for handler code Function_335895254_test_rebalance_in_with_different_topologies to complete bucket operations... Current : 40311 Expected : 40320 ...
|
2020-07-20 14:46:32 | INFO | MainProcess | test_thread | [basetestcase.sleep] sleep for 30 secs. Waiting for handler code Function_335895254_test_rebalance_in_with_different_topologies to complete bucket operations... Current : 40311 Expected : 40320 ...
|
2020-07-20 14:47:02 | INFO | MainProcess | test_thread | [basetestcase.sleep] sleep for 30 secs. Waiting for handler code Function_335895254_test_rebalance_in_with_different_topologies to complete bucket operations... Current : 40311 Expected : 40320 ...
|
2020-07-20 14:47:32 | INFO | MainProcess | test_thread | [basetestcase.sleep] sleep for 30 secs. Waiting for handler code Function_335895254_test_rebalance_in_with_different_topologies to complete bucket operations... Current : 40311 Expected : 40320 ...
|
2020-07-20 14:48:02 | INFO | MainProcess | test_thread | [basetestcase.sleep] sleep for 30 secs. Waiting for handler code Function_335895254_test_rebalance_in_with_different_topologies to complete bucket operations... Current : 40311 Expected : 40320 ...
|
2020-07-20 14:48:32 | INFO | MainProcess | test_thread | [basetestcase.sleep] sleep for 30 secs. Waiting for handler code Function_335895254_test_rebalance_in_with_different_topologies to complete bucket operations... Current : 40311 Expected : 40320 ...
|
Looking at the function code, if there is any timeout or exception, function is not writing it into the bucket.
function OnUpdate(doc, meta) {
|
var request = {
|
path : 'job/test_suite_executor/api/json?tree=jobs[component]'
|
}
|
try {
|
var response = curl("GET", server, request);
|
log('response body received from server:', response.body);
|
log('response headers received from server:', response.headers);
|
log('response status received from server:', response.status);
|
var res= new Uint8Array(response.body);
|
if(response.status == 200){
|
dst_bucket[meta.id]=response.body;
|
}
|
else{
|
dst_bucket[meta.id] = response.status;
|
}
|
}
|
catch (e) {
|
log('error:', e);
|
}
|
}
|
function OnDelete(meta) {
|
var request = {
|
path : 'job/test_suite_executor/api/json?tree=jobs[component]'
|
};
|
try {
|
var response = curl("GET", server, request);
|
log('response body received from server:', response.body);
|
log('response headers received from server:', response.headers);
|
log('response status received from server:', response.status);
|
var res= new Uint8Array(response.body);
|
if(response.status == 200){
|
delete dst_bucket[meta.id];
|
}
|
else{
|
delete dst_bucket[meta.id];
|
}
|
}
|
catch (e) {
|
log('error:', e);
|
}
|
}
|
Looking at the function log file from all 3 eventing nodes, we got 9 request timeout messages.
Function_335895254_test_rebalance_in_with_different_topologies.log
|
6868:2020-07-20T14:22:03.035+05:30 [INFO] "error:" {"message":"Unable to perform the request: Timeout was reached","stack":"Error\n at OnUpdate (Function_335895254_test_rebalance_in_with_different_topologies.js:7:21)"}
|
35789:2020-07-20T14:36:00.596+05:30 [INFO] "error:" {"message":"Unable to perform the request: Timeout was reached","stack":"Error\n at OnUpdate (Function_335895254_test_rebalance_in_with_different_topologies.js:7:21)"}
|
35790:2020-07-20T14:36:00.813+05:30 [INFO] "error:" {"message":"Unable to perform the request: Timeout was reached","stack":"Error\n at OnUpdate (Function_335895254_test_rebalance_in_with_different_topologies.js:7:21)"}
|
35791:2020-07-20T14:36:00.937+05:30 [INFO] "error:" {"message":"Unable to perform the request: Timeout was reached","stack":"Error\n at OnUpdate (Function_335895254_test_rebalance_in_with_different_topologies.js:7:21)"}
|
Function_335895254_test_rebalance_in_with_different_topologies.log
|
7039:2020-07-20T14:22:02.637+05:30 [INFO] "error:" {"message":"Unable to perform the request: Timeout was reached","stack":"Error\n at OnUpdate (Function_335895254_test_rebalance_in_with_different_topologies.js:7:21)"}
|
35942:2020-07-20T14:36:01.642+05:30 [INFO] "error:" {"message":"Unable to perform the request: Timeout was reached","stack":"Error\n at OnUpdate (Function_335895254_test_rebalance_in_with_different_topologies.js:7:21)"}
|
Function_335895254_test_rebalance_in_with_different_topologies.log
|
35344:2020-07-20T14:36:00.366+05:30 [INFO] "error:" {"message":"Unable to perform the request: Timeout was reached","stack":"Error\n at OnUpdate (Function_335895254_test_rebalance_in_with_different_topologies.js:7:21)"}
|
35345:2020-07-20T14:36:01.132+05:30 [INFO] "error:" {"message":"Unable to perform the request: Timeout was reached","stack":"Error\n at OnUpdate (Function_335895254_test_rebalance_in_with_different_topologies.js:7:21)"}
|
35346:2020-07-20T14:36:01.144+05:30 [INFO] "error:" {"message":"Unable to perform the request: Timeout was reached","stack":"Error\n at OnUpdate (Function_335895254_test_rebalance_in_with_different_topologies.js:7:21)"}
|
Vikas Chaudhary No changes in eventing in this area between the specified builds http://172.23.123.43:8000/getchangelog?product=couchbase-server&fromb=6.6.0-7873&tob=6.6.0-7883