是什么导致了 CouchDB changes_reader_die

Question

我正在尝试在两个数据库之间配置过滤复制双向。每个数据库在 _replicator 数据库中都有一个文档，用于设置对数据库的复制。每个数据库都有与过滤器相同的_design文档，并且它们得到相同的过滤器参数。

虽然我一直在查看网络，但我没有找到问题的原因。我希望你们能帮助我。

---

日志输出：

 [Fri, 26 Aug 2016 19:36:31 GMT] [error] [<0.22247.80>] ** Generic server <0.22247.80> terminating 
** Last message in was {'EXIT',<0.22219.80>,changes_reader_died}
** When Server state == {state,<0.22219.80>,<0.22249.80>,20,
                            {httpdb,
                                "REPLACEDFORSECURITYREASONS",
                                nil,
                                [{"Accept","application/json"},
                                 {"User-Agent","CouchDB/1.6.1"}],
                                30000,
                                [{socket_options,
                                     [{keepalive,true},{nodelay,false}]}],
                                10,250,<0.22065.80>,20},
                            {httpdb,
                                "http:REPLACEDFORSECURITYREASONS",
                                nil,
                                [{"Accept","application/json"},
                                 {"User-Agent","CouchDB/1.6.1"}],
                                30000,
                                [{socket_options,
                                     [{keepalive,true},{nodelay,false}]}],
                                10,250,<0.22223.80>,20},
                            [],nil,nil,nil,
                            {rep_stats,0,0,0,0,0},
                            nil,nil,
                            {batch,[],0}}
** Reason for termination == 
** changes_reader_died

[Fri, 26 Aug 2016 19:36:31 GMT] [error] [<0.22243.80>] {error_report,<0.34.0>,
                        {<0.22243.80>,crash_report,
                         [[{initial_call,
                            {couch_replicator_worker,init,['Argument__1']}},
                           {pid,<0.22243.80>},
                           {registered_name,[]},
                           {error_info,
                            {exit,changes_reader_died,
                             [{gen_server,terminate,6,
                               [{file,"gen_server.erl"},{line,744}]},
                              {proc_lib,init_p_do_apply,3,
                               [{file,"proc_lib.erl"},{line,239}]}]}},
                           {ancestors,
                            [<0.22219.80>,couch_replicator_job_sup,
                             couch_primary_services,couch_server_sup,
                             <0.35.0>]},
                           {messages,[]},
                           {links,[<0.22244.80>]},
                           {dictionary,
                            [{last_stats_report,{1472,240191,741233}}]},
                           {trap_exit,true},
                           {status,running},
                           {heap_size,233},
                           {stack_size,27},
                           {reductions,158}],
                          [{neighbour,
                            [{pid,<0.22244.80>},
                             {registered_name,[]},
                             {initial_call,{erlang,apply,2}},
                             {current_function,
                              {couch_replicator_worker,queue_fetch_loop,5}},
                             {ancestors,[]},
                             {messages,[]},
                             {links,[<0.22243.80>]},
                             {dictionary,[]},
                             {trap_exit,false},
                             {status,waiting},
                             {heap_size,610},
                             {stack_size,10},
                             {reductions,4}]}]]}}
[Fri, 26 Aug 2016 19:36:31 GMT] [error] [<0.22247.80>] {error_report,<0.34.0>,
                        {<0.22247.80>,crash_report,
                         [[{initial_call,
                            {couch_replicator_worker,init,['Argument__1']}},
                           {pid,<0.22247.80>},
                           {registered_name,[]},
                           {error_info,
                            {exit,changes_reader_died,
                             [{gen_server,terminate,6,
                               [{file,"gen_server.erl"},{line,744}]},
                              {proc_lib,init_p_do_apply,3,
                               [{file,"proc_lib.erl"},{line,239}]}]}},
                           {ancestors,
                            [<0.22219.80>,couch_replicator_job_sup,
                             couch_primary_services,couch_server_sup,
                             <0.35.0>]},
                           {messages,[]},
                           {links,[<0.22249.80>]},
                           {dictionary,
                            [{last_stats_report,{1472,240191,741235}}]},
                           {trap_exit,true},
                           {status,running},
                           {heap_size,233},
                           {stack_size,27},
                           {reductions,162}],
                          [{neighbour,
                            [{pid,<0.22249.80>},
                             {registered_name,[]},
                             {initial_call,{erlang,apply,2}},
                             {current_function,
                              {couch_replicator_worker,queue_fetch_loop,5}},
                             {ancestors,[]},
                             {messages,[]},
                             {links,[<0.22247.80>]},
                             {dictionary,[]},
                             {trap_exit,false},
                             {status,waiting},
                             {heap_size,610},
                             {stack_size,10},
                             {reductions,4}]}]]}}

最好的问候。

Answer 1

在深入分析日志的时候，发现changes_read_died之前有超时错误。

错误非常明确：

Fri, 26 Aug 2016 20:01:06 GMT] [info] [<0.2238.0>] Replication `"c48f6c26aa44689de43ee5ffaa18c7ad+continuous"` is using:
    4 worker processes
    a worker batch size of 500
    20 HTTP connections
    a connection timeout of 30000 milliseconds
    10 retries per request
    socket options are: [{keepalive,true},{nodelay,false}]
[Fri, 26 Aug 2016 20:01:06 GMT] [info] [<0.2204.0>] XXX.XXX.X.XX- - GET /akpaper/_changes?filter=global%2FbySite&IDSITE=MILLS2&feed=continuous&style=all_docs&since=0&heartbeat=10000 200
[Fri, 26 Aug 2016 20:01:06 GMT] [error] [<0.2204.0>] OS Process Error <0.204.0> :: {<<"compilation_error">>,
                                                    <<"Expression does not eval to a function. (ffunction(doc, req) {    return doc._deleted || doc.IDSITE == req.query.IDSITE;})">>}
[Fri, 26 Aug 2016 20:01:06 GMT] [info] [<0.2204.0>] XXX.XXX.X.XX - - GET /akpaper/_changes?filter=global%2FbySite&IDSITE=MILLS2&feed=continuous&style=all_docs&since=0&heartbeat=10000 500
[Fri, 26 Aug 2016 20:01:06 GMT] [error] [<0.2204.0>] httpd 500 error response:
 {"error":"compilation_error","reason":"Expression does not eval to a function. (ffunction(doc, req) {    return doc._deleted || doc.IDSITE == req.query.IDSITE;})"}

我为纠正这个问题所做的只是纠正我的过滤器函数，它不能是 eval。

Answer 2

对我来说，“更改”解析器失败，因此消息：changes_reader_dies

查看复制文档，似乎它将 Content-Type 设置为 JSON 并且以某种方式无法解析更改。删除该行为我修复了它：

不好：

{
    "_id": "repl/...",
    "_rev": "8-76d8a4dd87f5911b5dccb2527b2304",
    "source": {
        "url": "
        "headers": {
              "Authorization": "Basic FaBNwB...",
              "Content-Type": "application/json"
        }
    "target": ...
    ...
}

好：

{
    "_id": "repl/...",
    "_rev": "8-76d8a4dd87f5911b5dccb2527b2304",
    "source": {
        "url": "
        "headers": {
              "Authorization": "Basic FaBNwB..."
        }
    "target": ...
    ...
}