Skip to content
This repository has been archived by the owner on Sep 22, 2024. It is now read-only.

ERROR: timed out while collecting data from node #54

Open
Arkham opened this issue May 22, 2017 · 4 comments
Open

ERROR: timed out while collecting data from node #54

Arkham opened this issue May 22, 2017 · 4 comments
Assignees
@arkgil

Comments

@Arkham
Copy link

Arkham commented May 22, 2017

Hi guys,

I was trying out EPL to visualize a Flow experiment. You can find the code here: https://github.com/Arkham/flow_lightning

If I try to connect EPL to the running node I get this error a lot of times

ERROR: timed out while collecting data from node

And after that the epl_tracer crashes with this message

=ERROR REPORT==== 22-May-2017::16:13:12 ===
** Generic server epl_tracer terminating
** Last message in was {#Ref<0.0.4.274>,
                        [{process_count,107},
                         {memory_total,1712777168},
                         {spawn,
                          [{<6853.185.0>,
                            {proc_lib,init_p,
                             [<6853.175.0>,
                              [<6853.77.0>],
                              gen,init_it,
                              [gen_server,<6853.175.0>,self,
                               'Elixir.Flow.Coordinator',
                               {<6853.175.0>,
                                #{'__struct__' => 'Elixir.Flow',
                                  operations =>
                                   [{reduce,
                                     #Fun<Elixir.FlowLightning.1.121366654>,
                                     #Fun<Elixir.FlowLightning.2.121366654>}],
                                  options => [{stages,4}],
                                  producers =>
                                   {flows,
                                    [#{'__struct__' => 'Elixir.Flow',
                                       operations =>
                                        [{mapper,flat_map,
                                          [#Fun<Elixir.FlowLightning.0.121366654>]}],
                                       options => [{stages,4}],
                                       producers =>
                                        {enumerables,
                                         [#{'__struct__' =>
                                             'Elixir.File.Stream',
                                            line_or_bytes => line,
                                            modes => [raw,read_ahead,binary],
                                            path => <<"priv/words_by_8.txt">>,
                                            raw => true}]},
                                       window =>
                                        #{'__struct__' =>
                                           'Elixir.Flow.Window.Global',
                                          periodically => [],
                                          trigger => nil}}]},
                                  window =>
                                   #{'__struct__' =>
                                      'Elixir.Flow.Window.Global',
                                     periodically => [],trigger => nil}},
                                producer_consumer,[],
                                [{demand,accumulate}]},
                               [{demand,accumulate}]]]},
                            {1495,465965,217124}},
                           {<6853.186.0>,
                            {proc_lib,init_p,
                             [<6853.185.0>,
                              [<6853.175.0>,<6853.77.0>],
                              gen,init_it,
                              [gen_server,<6853.185.0>,<6853.185.0>,
                               supervisor,
                               {self,'Elixir.Supervisor.Default',
                                {ok,
                                 {{simple_one_for_one,0,5},
                                  [{'Elixir.GenStage',
                                    {'Elixir.GenStage',start_link,[]},
                                    transient,5000,worker,
                                    ['Elixir.GenStage']}]}}},
                               []]]},
                            {1495,465965,217175}},
                           {<6853.187.0>,
                            {proc_lib,init_p,
                             [<6853.186.0>,
                              [<6853.185.0>,<6853.175.0>,<6853.77.0>],
                              gen,init_it,
                              [gen_server,<6853.186.0>,<6853.186.0>,
                               'Elixir.GenStage',
                               {'Elixir.GenStage.Streamer',
                                {#{'__struct__' => 'Elixir.File.Stream',
                                   line_or_bytes => line,
                                   modes => [raw,read_ahead,binary],
                                   path => <<"priv/words_by_8.txt">>,
                                   raw => true},
                                 [{consumers,permanent},{demand,accumulate}]}},
                               [{consumers,permanent},{demand,accumulate}]]]},
                            {1495,465965,223182}},
                           {<6853.188.0>,
                            {proc_lib,init_p,
                             [<6853.186.0>,
                              [<6853.185.0>,<6853.175.0>,<6853.77.0>],
                              gen,init_it,
                              [gen_server,<6853.186.0>,<6853.186.0>,
                               'Elixir.GenStage',
                               {'Elixir.Flow.MapReducer',
                                {producer_consumer,
                                 [{subscribe_to,
                                   [{<6853.187.0>,[{partition,0}]}]},
                                  {dispatcher,
                                   {'Elixir.GenStage.PartitionDispatcher',
                                    [{partitions,
                                      #{'__struct__' => 'Elixir.Range',
                                        first => 0,last => 3}},
                                     {hash,
                                      #Fun<Elixir.Flow.Materialize.18.45510982>}]}}],
                                 {0,4},
                                 #Fun<Elixir.Flow.Window.Global.2.31322697>,
                                 #Fun<Elixir.Flow.Materialize.32.45510982>,
                                 #Fun<Elixir.Flow.Materialize.33.45510982>}},
                               []]]},
                            {1495,465965,227357}},
                           {<6853.189.0>,
                            {proc_lib,init_p,
                             [<6853.186.0>,
                              [<6853.185.0>,<6853.175.0>,<6853.77.0>],
                              gen,init_it,
                              [gen_server,<6853.186.0>,<6853.186.0>,
                               'Elixir.GenStage',
                               {'Elixir.Flow.MapReducer',
                                {producer_consumer,
                                 [{subscribe_to,
                                   [{<6853.187.0>,[{partition,1}]}]},
                                  {dispatcher,
                                   {'Elixir.GenStage.PartitionDispatcher',
                                    [{partitions,
                                      #{'__struct__' => 'Elixir.Range',
                                        first => 0,last => 3}},
                                     {hash,
                                      #Fun<Elixir.Flow.Materialize.18.45510982>}]}}],
                                 {1,4},
                                 #Fun<Elixir.Flow.Window.Global.2.31322697>,
                                 #Fun<Elixir.Flow.Materialize.32.45510982>,
                                 #Fun<Elixir.Flow.Materialize.33.45510982>}},
                               []]]},
                            {1495,465965,230667}},
                           {<6853.190.0>,
                            {proc_lib,init_p,
                             [<6853.186.0>,
                              [<6853.185.0>,<6853.175.0>,<6853.77.0>],
                              gen,init_it,
                              [gen_server,<6853.186.0>,<6853.186.0>,
                               'Elixir.GenStage',
                               {'Elixir.Flow.MapReducer',
                                {producer_consumer,
                                 [{subscribe_to,
                                   [{<6853.187.0>,[{partition,2}]}]},
                                  {dispatcher,
                                   {'Elixir.GenStage.PartitionDispatcher',
                                    [{partitions,
                                      #{'__struct__' => 'Elixir.Range',
                                        first => 0,last => 3}},
                                     {hash,
                                      #Fun<Elixir.Flow.Materialize.18.45510982>}]}}],
                                 {2,4},
                                 #Fun<Elixir.Flow.Window.Global.2.31322697>,
                                 #Fun<Elixir.Flow.Materialize.32.45510982>,
                                 #Fun<Elixir.Flow.Materialize.33.45510982>}},
                               []]]},
                            {1495,465965,230748}},
                           {<6853.191.0>,
                            {proc_lib,init_p,
                             [<6853.186.0>,
                              [<6853.185.0>,<6853.175.0>,<6853.77.0>],
                              gen,init_it,
                              [gen_server,<6853.186.0>,<6853.186.0>,
                               'Elixir.GenStage',
                               {'Elixir.Flow.MapReducer',
                                {producer_consumer,
                                 [{subscribe_to,
                                   [{<6853.187.0>,[{partition,3}]}]},
                                  {dispatcher,
                                   {'Elixir.GenStage.PartitionDispatcher',
                                    [{partitions,
                                      #{'__struct__' => 'Elixir.Range',
                                        first => 0,last => 3}},
                                     {hash,
                                      #Fun<Elixir.Flow.Materialize.18.45510982>}]}}],
                                 {3,4},
                                 #Fun<Elixir.Flow.Window.Global.2.31322697>,
                                 #Fun<Elixir.Flow.Materialize.32.45510982>,
                                 #Fun<Elixir.Flow.Materialize.33.45510982>}},
                               []]]},
                            {1495,465965,230815}},
                           {<6853.192.0>,
                            {proc_lib,init_p,
                             [<6853.186.0>,
                              [<6853.185.0>,<6853.175.0>,<6853.77.0>],
                              gen,init_it,
                              [gen_server,<6853.186.0>,<6853.186.0>,
                               'Elixir.GenStage',
                               {'Elixir.Flow.MapReducer',
                                {producer_consumer,
                                 [{subscribe_to,
                                   [{<6853.188.0>,[{partition,0}]},
                                    {<6853.189.0>,[{partition,0}]},
                                    {<6853.190.0>,[{partition,0}]},
                                    {<6853.191.0>,[{partition,0}]}]}],
                                 {0,4},
                                 #Fun<Elixir.Flow.Window.Global.2.31322697>,
                                 #Fun<Elixir.FlowLightning.1.121366654>,
                                 #Fun<Elixir.Flow.Materialize.3.45510982>}},
                               []]]},
                            {1495,465965,230883}},
                           {<6853.193.0>,
                            {proc_lib,init_p,
                             [<6853.186.0>,
                              [<6853.185.0>,<6853.175.0>,<6853.77.0>],
                              gen,init_it,
                              [gen_server,<6853.186.0>,<6853.186.0>,
                               'Elixir.GenStage',
                               {'Elixir.Flow.MapReducer',
                                {producer_consumer,
                                 [{subscribe_to,
                                   [{<6853.188.0>,[{partition,1}]},
                                    {<6853.189.0>,[{partition,1}]},
                                    {<6853.190.0>,[{partition,1}]},
                                    {<6853.191.0>,[{partition,1}]}]}],
                                 {1,4},
                                 #Fun<Elixir.Flow.Window.Global.2.31322697>,
                                 #Fun<Elixir.FlowLightning.1.121366654>,
                                 #Fun<Elixir.Flow.Materialize.3.45510982>}},
                               []]]},
                            {1495,465965,231011}},
                           {<6853.194.0>,
                            {proc_lib,init_p,
                             [<6853.186.0>,
                              [<6853.185.0>,<6853.175.0>,<6853.77.0>],
                              gen,init_it,
                              [gen_server,<6853.186.0>,<6853.186.0>,
                               'Elixir.GenStage',
                               {'Elixir.Flow.MapReducer',
                                {producer_consumer,
                                 [{subscribe_to,
                                   [{<6853.188.0>,[{partition,2}]},
                                    {<6853.189.0>,[{partition,2}]},
                                    {<6853.190.0>,[{partition,2}]},
                                    {<6853.191.0>,[{partition,2}]}]}],
                                 {2,4},
                                 #Fun<Elixir.Flow.Window.Global.2.31322697>,
                                 #Fun<Elixir.FlowLightning.1.121366654>,
                                 #Fun<Elixir.Flow.Materialize.3.45510982>}},
                               []]]},
                            {1495,465965,231123}},
                           {<6853.195.0>,
                            {proc_lib,init_p,
                             [<6853.186.0>,
                              [<6853.185.0>,<6853.175.0>,<6853.77.0>],
                              gen,init_it,
                              [gen_server,<6853.186.0>,<6853.186.0>,
                               'Elixir.GenStage',
                               {'Elixir.Flow.MapReducer',
                                {producer_consumer,
                                 [{subscribe_to,
                                   [{<6853.188.0>,[{partition,3}]},
                                    {<6853.189.0>,[{partition,3}]},
                                    {<6853.190.0>,[{partition,3}]},
                                    {<6853.191.0>,[{partition,3}]}]}],
                                 {3,4},
                                 #Fun<Elixir.Flow.Window.Global.2.31322697>,
                                 #Fun<Elixir.FlowLightning.1.121366654>,
                                 #Fun<Elixir.Flow.Materialize.3.45510982>}},
                               []]]},
                            {1495,465965,231231}},
                           {<6853.196.0>,
                            {erlang,apply,
                             [#Fun<Elixir.GenStage.13.64651076>,[]]},
                            {1495,465965,231361}}]},
                         {spawn_,true},
                         {exit,[{<6853.176.0>,normal,{1495,465965,205064}}]},
                         {exit_,true},
                         {send,
                          [{{code_server,<6853.175.0>},0,9},
                           {{code_server,<6853.185.0>},0,2},
                           {{code_server,<6853.186.0>},0,1},
                           {{code_server,<6853.187.0>},0,3},
                           {{code_server,<6853.188.0>},0,2},
                           {{#Port<6853.674>,<6853.54.0>},2,6},
                           {{#Port<6853.6204>,<6853.179.0>},1,0},
                           {{#Port<6853.6217>,<6853.4.0>},1,0},
                           {{#Port<6853.6218>,<6853.4.0>},1,0},
                           {{#Port<6853.6219>,<6853.4.0>},1,0},
                           {{#Port<6853.6220>,<6853.4.0>},1,0},
                           {{#Port<6853.6221>,<6853.4.0>},1,0},
                           {{#Port<6853.6222>,<6853.4.0>},1,0},
                           {{#Port<6853.6223>,<6853.4.0>},1,0},
                           {{#Port<6853.6224>,<6853.4.0>},1,0},
                           {{#Port<6853.6225>,<6853.4.0>},1,0},
                           {{#Port<6853.6226>,<6853.4.0>},1,0},
                           {{#Port<6853.6227>,<6853.4.0>},1,0},
                           {{#Port<6853.6228>,<6853.4.0>},1,0},
                           {{#Port<6853.6229>,<6853.4.0>},1,0},
                           {{#Port<6853.6230>,<6853.4.0>},1,0},
                           {{#Port<6853.6231>,<6853.4.0>},1,0},
                           {{#Port<6853.6232>,<6853.4.0>},1,0},
                           {{#Port<6853.6233>,<6853.4.0>},1,0},
                           {{#Port<6853.6234>,<6853.4.0>},1,0},
                           {{#Port<6853.6235>,<6853.4.0>},1,0},
                           {{#Port<6853.6236>,<6853.4.0>},1,0},
                           {{#Port<6853.6237>,<6853.4.0>},1,0},
                           {{#Port<6853.6238>,<6853.4.0>},1,0},
                           {{#Port<6853.6239>,<6853.4.0>},1,0},
                           {{#Port<6853.6240>,<6853.4.0>},1,0},
                           {{#Port<6853.6241>,<6853.4.0>},1,0},
                           {{#Port<6853.6242>,<6853.4.0>},1,0},
                           {{#Port<6853.6243>,<6853.4.0>},1,0},
                           {{#Port<6853.6244>,<6853.4.0>},1,0},
                           {{#Port<6853.6245>,<6853.4.0>},1,0},
                           {{#Port<6853.6246>,<6853.4.0>},1,0},
                           {{#Port<6853.6247>,<6853.4.0>},1,0},
                           {{#Port<6853.6248>,<6853.4.0>},1,0},
                           {{#Port<6853.6249>,<6853.4.0>},1,0},
                           {{#Port<6853.6250>,<6853.4.0>},1,0},
                           {{#Port<6853.6251>,<6853.4.0>},1,0},
                           {{#Port<6853.6252>,<6853.4.0>},1,0},
                           {{#Port<6853.6253>,<6853.4.0>},1,0},
                           {{#Port<6853.6254>,<6853.4.0>},1,0},
                           {{#Port<6853.6255>,<6853.4.0>},1,0},
                           {{#Port<6853.6256>,<6853.4.0>},1,0},
                           {{#Port<6853.6257>,<6853.4.0>},1,0},
                           {{#Port<6853.6258>,<6853.4.0>},1,0},
                           {{#Port<6853.6259>,<6853.4.0>},1,0},
                           {{#Port<6853.6260>,<6853.4.0>},1,0},
                           {{#Port<6853.6261>,<6853.4.0>},1,0},
                           {{#Port<6853.6262>,<6853.4.0>},1,0},
                           {{#Port<6853.6263>,<6853.4.0>},1,0},
                           {{#Port<6853.6264>,<6853.4.0>},1,0},
                           {{#Port<6853.6265>,<6853.4.0>},1,0},
                           {{#Port<6853.6266>,<6853.4.0>},1,0},
                           {{#Port<6853.6267>,<6853.4.0>},1,0},
                           {{#Port<6853.6268>,<6853.4.0>},1,0},
                           {{#Port<6853.6269>,<6853.4.0>},1,0},
                           {{#Port<6853.6270>,<6853.4.0>},1,0},
                           {{#Port<6853.6271>,<6853.4.0>},1,0},
                           {{#Port<6853.6272>,<6853.4.0>},1,0},
                           {{#Port<6853.6273>,<6853.4.0>},1,0},
                           {{#Port<6853.6274>,<6853.4.0>},1,0},
                           {{#Port<6853.6275>,<6853.4.0>},1,0},
                           {{#Port<6853.6276>,<6853.4.0>},1,0},
                           {{#Port<6853.6277>,<6853.4.0>},1,0},
                           {{#Port<6853.6278>,<6853.4.0>},1,0},
                           {{#Port<6853.6279>,<6853.4.0>},1,0},
                           {{#Port<6853.6280>,<6853.4.0>},1,0},
                           {{#Port<6853.6281>,<6853.4.0>},1,0},
                           {{#Port<6853.6282>,<6853.4.0>},1,0},
                           {{#Port<6853.6283>,<6853.187.0>},52809,0},
                           {{<6853.4.0>,<6853.36.0>},66,66},
                           {{<6853.36.0>,<6853.175.0>},9,0},
                           {{<6853.36.0>,<6853.185.0>},2,0},
                           {{<6853.36.0>,<6853.186.0>},1,0},
                           {{<6853.36.0>,<6853.187.0>},3,0},
                           {{<6853.36.0>,<6853.188.0>},2,0},
                           {{<6853.54.0>,<6853.56.0>},2,4},
                           {{<6853.56.0>,<6853.176.0>},1,0},
                           {{<6853.77.0>,<6853.175.0>},1,0},
                           {{<6853.77.0>,<6853.176.0>},0,1},
                           {{<6853.175.0>,<6853.185.0>},1,2},
                           {{<6853.175.0>,<6853.187.0>},1,0},
                           {{<6853.175.0>,<6853.196.0>},1,1},
                           {{<6853.179.0>,<6853.184.0>},1,0},
                           {{<6853.185.0>,<6853.186.0>},9,10},
                           {{<6853.186.0>,<6853.187.0>},0,1},
                           {{<6853.186.0>,<6853.188.0>},0,1},
                           {{<6853.186.0>,<6853.189.0>},0,1},
                           {{<6853.186.0>,<6853.190.0>},0,1},
                           {{<6853.186.0>,<6853.191.0>},0,1},
                           {{<6853.186.0>,<6853.192.0>},0,1},
                           {{<6853.186.0>,<6853.193.0>},0,1},
                           {{<6853.186.0>,<6853.194.0>},0,1},
                           {{<6853.186.0>,<6853.195.0>},0,1},
                           {{<6853.187.0>,<6853.188.0>},26,29},
                           {{<6853.187.0>,<6853.189.0>},26,28},
                           {{<6853.187.0>,<6853.190.0>},26,28},
                           {{<6853.187.0>,<6853.191.0>},23,26},
                           {{<6853.188.0>,<6853.192.0>},107,41},
                           {{<6853.188.0>,<6853.193.0>},96,47},
                           {{<6853.188.0>,<6853.194.0>},104,43},
                           {{<6853.188.0>,<6853.195.0>},102,44},
                           {{<6853.189.0>,<6853.192.0>},110,44},
                           {{<6853.189.0>,<6853.193.0>},88,39},
                           {{<6853.189.0>,<6853.194.0>},94,44},
                           {{<6853.189.0>,<6853.195.0>},94,43},
                           {{<6853.190.0>,<6853.192.0>},73,37},
                           {{<6853.190.0>,<6853.193.0>},83,43},
                           {{<6853.190.0>,<6853.194.0>},78,43},
                           {{<6853.190.0>,<6853.195.0>},77,43},
                           {{<6853.191.0>,<6853.192.0>},88,39},
                           {{<6853.191.0>,<6853.193.0>},88,38},
                           {{<6853.191.0>,<6853.194.0>},88,39},
                           {{<6853.191.0>,<6853.195.0>},83,38},
                           {{<6853.192.0>,<6853.196.0>},0,2},
                           {{<6853.193.0>,<6853.196.0>},0,2},
                           {{<6853.194.0>,<6853.196.0>},0,2},
                           {{<6853.195.0>,<6853.196.0>},0,2}]},
                         {send_,true},
                         {send_self,[]},
                         {send_self_,true},
                         {'receive',
                          [{#Port<6853.674>,6,61},
                           {#Port<6853.6204>,1,12},
                           {#Port<6853.6217>,2,25},
                           {#Port<6853.6218>,2,25},
                           {#Port<6853.6219>,2,25},
                           {#Port<6853.6220>,2,25},
                           {#Port<6853.6221>,2,25},
                           {#Port<6853.6222>,2,25},
                           {#Port<6853.6223>,2,25},
                           {#Port<6853.6224>,2,25},
                           {#Port<6853.6225>,2,25},
                           {#Port<6853.6226>,2,25},
                           {#Port<6853.6227>,2,25},
                           {#Port<6853.6228>,2,25},
                           {#Port<6853.6229>,2,25},
                           {#Port<6853.6230>,2,25},
                           {#Port<6853.6231>,2,25},
                           {#Port<6853.6232>,2,25},
                           {#Port<6853.6233>,2,25},
                           {#Port<6853.6234>,2,25},
                           {#Port<6853.6235>,2,25},
                           {#Port<6853.6236>,2,25},
                           {#Port<6853.6237>,2,25},
                           {#Port<6853.6238>,2,25},
                           {#Port<6853.6239>,2,25},
                           {#Port<6853.6240>,2,25},
                           {#Port<6853.6241>,2,25},
                           {#Port<6853.6242>,2,25},
                           {#Port<6853.6243>,2,25},
                           {#Port<6853.6244>,2,25},
                           {#Port<6853.6245>,2,25},
                           {#Port<6853.6246>,2,25},
                           {#Port<6853.6247>,2,25},
                           {#Port<6853.6248>,2,25},
                           {#Port<6853.6249>,2,25},
                           {#Port<6853.6250>,2,25},
                           {#Port<6853.6251>,2,25},
                           {#Port<6853.6252>,2,25},
                           {#Port<6853.6253>,2,25},
                           {#Port<6853.6254>,2,25},
                           {#Port<6853.6255>,2,25},
                           {#Port<6853.6256>,2,25},
                           {#Port<6853.6257>,2,25},
                           {#Port<6853.6258>,2,25},
                           {#Port<6853.6259>,2,25},
                           {#Port<6853.6260>,2,25},
                           {#Port<6853.6261>,2,25},
                           {#Port<6853.6262>,2,25},
                           {#Port<6853.6263>,2,25},
                           {#Port<6853.6264>,2,25},
                           {#Port<6853.6265>,2,25},
                           {#Port<6853.6266>,2,25},
                           {#Port<6853.6267>,2,25},
                           {#Port<6853.6268>,2,25},
                           {#Port<6853.6269>,2,25},
                           {#Port<6853.6270>,2,25},
                           {#Port<6853.6271>,2,25},
                           {#Port<6853.6272>,2,25},
                           {#Port<6853.6273>,2,25},
                           {#Port<6853.6274>,2,25},
                           {#Port<6853.6275>,2,25},
                           {#Port<6853.6276>,2,25},
                           {#Port<6853.6277>,2,25},
                           {#Port<6853.6278>,2,25},
                           {#Port<6853.6279>,2,25},
                           {#Port<6853.6280>,2,25},
                           {#Port<6853.6281>,2,25},
                           {#Port<6853.6282>,2,25},
                           {#Port<6853.6283>,52809,739326},
                           {<6853.4.0>,198,13996},
                           {<6853.36.0>,83,3499},
                           {<6853.54.0>,6,203},
                           {<6853.56.0>,2,20},
                           {<6853.77.0>,1,10},
                           {<6853.175.0>,13,418},
                           {<6853.176.0>,1,13},
                           {<6853.179.0>,1,3},
                           {<6853.185.0>,13,110},
                           {<6853.186.0>,19,1149},
                           {<6853.187.0>,52924,1585733},
                           {<6853.188.0>,203,110571},
                           {<6853.189.0>,196,110494},
                           {<6853.190.0>,192,110442},
                           {<6853.191.0>,177,98256},
                           {<6853.192.0>,380,826291},
                           {<6853.193.0>,357,827477},
                           {<6853.194.0>,366,825743},
                           {<6853.195.0>,358,828007},
                           {<6853.196.0>,1,6}]},
                         {receive_,true},
                         {trace,[]},
                         {trace_,true}]}
** When Server state == {state,[<0.194.0>,<0.86.0>,<0.85.0>],
                               #Ref<0.0.4.274>,<6853.184.0>,3}
** Reason for termination ==
** {{not_implemented,
     {#Ref<0.0.4.274>,
      [{process_count,107},
       {memory_total,1712777168},
       {spawn,
        [{<6853.185.0>,
          {proc_lib,init_p,
           [<6853.175.0>,
            [<6853.77.0>],
            gen,init_it,
            [gen_server,<6853.175.0>,self,'Elixir.Flow.Coordinator',
             {<6853.175.0>,
              #{'__struct__' => 'Elixir.Flow',
                operations =>
                 [{reduce,#Fun<Elixir.FlowLightning.1.121366654>,
                   #Fun<Elixir.FlowLightning.2.121366654>}],
                options => [{stages,4}],
                producers =>
                 {flows,
                  [#{'__struct__' => 'Elixir.Flow',
                     operations =>
                      [{mapper,flat_map,
                        [#Fun<Elixir.FlowLightning.0.121366654>]}],
                     options => [{stages,4}],
                     producers =>
                      {enumerables,
                       [#{'__struct__' => 'Elixir.File.Stream',
                          line_or_bytes => line,
                          modes => [raw,read_ahead,binary],
                          path => <<"priv/words_by_8.txt">>,raw => true}]},
                     window =>
                      #{'__struct__' => 'Elixir.Flow.Window.Global',
                        periodically => [],trigger => nil}}]},
                window =>
                 #{'__struct__' => 'Elixir.Flow.Window.Global',
                   periodically => [],trigger => nil}},
              producer_consumer,[],
              [{demand,accumulate}]},
             [{demand,accumulate}]]]},
          {1495,465965,217124}},
         {<6853.186.0>,
          {proc_lib,init_p,
           [<6853.185.0>,
            [<6853.175.0>,<6853.77.0>],
            gen,init_it,
            [gen_server,<6853.185.0>,<6853.185.0>,supervisor,
             {self,'Elixir.Supervisor.Default',
              {ok,
               {{simple_one_for_one,0,5},
                [{'Elixir.GenStage',
                  {'Elixir.GenStage',start_link,[]},
                  transient,5000,worker,
                  ['Elixir.GenStage']}]}}},
             []]]},
          {1495,465965,217175}},
         {<6853.187.0>,
          {proc_lib,init_p,
           [<6853.186.0>,
            [<6853.185.0>,<6853.175.0>,<6853.77.0>],
            gen,init_it,
            [gen_server,<6853.186.0>,<6853.186.0>,'Elixir.GenStage',
             {'Elixir.GenStage.Streamer',
              {#{'__struct__' => 'Elixir.File.Stream',line_or_bytes => line,
                 modes => [raw,read_ahead,binary],
                 path => <<"priv/words_by_8.txt">>,raw => true},
               [{consumers,permanent},{demand,accumulate}]}},
             [{consumers,permanent},{demand,accumulate}]]]},
          {1495,465965,223182}},
         {<6853.188.0>,
          {proc_lib,init_p,
           [<6853.186.0>,
            [<6853.185.0>,<6853.175.0>,<6853.77.0>],
            gen,init_it,
            [gen_server,<6853.186.0>,<6853.186.0>,'Elixir.GenStage',
             {'Elixir.Flow.MapReducer',
              {producer_consumer,
               [{subscribe_to,[{<6853.187.0>,[{partition,0}]}]},
                {dispatcher,
                 {'Elixir.GenStage.PartitionDispatcher',
                  [{partitions,
                    #{'__struct__' => 'Elixir.Range',first => 0,last => 3}},
                   {hash,#Fun<Elixir.Flow.Materialize.18.45510982>}]}}],
               {0,4},
               #Fun<Elixir.Flow.Window.Global.2.31322697>,
               #Fun<Elixir.Flow.Materialize.32.45510982>,
               #Fun<Elixir.Flow.Materialize.33.45510982>}},
             []]]},
          {1495,465965,227357}},
         {<6853.189.0>,
          {proc_lib,init_p,
           [<6853.186.0>,
            [<6853.185.0>,<6853.175.0>,<6853.77.0>],
            gen,init_it,
            [gen_server,<6853.186.0>,<6853.186.0>,'Elixir.GenStage',
             {'Elixir.Flow.MapReducer',
              {producer_consumer,
               [{subscribe_to,[{<6853.187.0>,[{partition,1}]}]},
                {dispatcher,
                 {'Elixir.GenStage.PartitionDispatcher',
                  [{partitions,
                    #{'__struct__' => 'Elixir.Range',first => 0,last => 3}},
                   {hash,#Fun<Elixir.Flow.Materialize.18.45510982>}]}}],
               {1,4},
               #Fun<Elixir.Flow.Window.Global.2.31322697>,
               #Fun<Elixir.Flow.Materialize.32.45510982>,
               #Fun<Elixir.Flow.Materialize.33.45510982>}},
             []]]},
          {1495,465965,230667}},
         {<6853.190.0>,
          {proc_lib,init_p,
           [<6853.186.0>,
            [<6853.185.0>,<6853.175.0>,<6853.77.0>],
            gen,init_it,
            [gen_server,<6853.186.0>,<6853.186.0>,'Elixir.GenStage',
             {'Elixir.Flow.MapReducer',
              {producer_consumer,
               [{subscribe_to,[{<6853.187.0>,[{partition,2}]}]},
                {dispatcher,
                 {'Elixir.GenStage.PartitionDispatcher',
                  [{partitions,
                    #{'__struct__' => 'Elixir.Range',first => 0,last => 3}},
                   {hash,#Fun<Elixir.Flow.Materialize.18.45510982>}]}}],
               {2,4},
               #Fun<Elixir.Flow.Window.Global.2.31322697>,
               #Fun<Elixir.Flow.Materialize.32.45510982>,
               #Fun<Elixir.Flow.Materialize.33.45510982>}},
             []]]},
          {1495,465965,230748}},
         {<6853.191.0>,
          {proc_lib,init_p,
           [<6853.186.0>,
            [<6853.185.0>,<6853.175.0>,<6853.77.0>],
            gen,init_it,
            [gen_server,<6853.186.0>,<6853.186.0>,'Elixir.GenStage',
             {'Elixir.Flow.MapReducer',
              {producer_consumer,
               [{subscribe_to,[{<6853.187.0>,[{partition,3}]}]},
                {dispatcher,
                 {'Elixir.GenStage.PartitionDispatcher',
                  [{partitions,
                    #{'__struct__' => 'Elixir.Range',first => 0,last => 3}},
                   {hash,#Fun<Elixir.Flow.Materialize.18.45510982>}]}}],
               {3,4},
               #Fun<Elixir.Flow.Window.Global.2.31322697>,
               #Fun<Elixir.Flow.Materialize.32.45510982>,
               #Fun<Elixir.Flow.Materialize.33.45510982>}},
             []]]},
          {1495,465965,230815}},
         {<6853.192.0>,
          {proc_lib,init_p,
           [<6853.186.0>,
            [<6853.185.0>,<6853.175.0>,<6853.77.0>],
            gen,init_it,
            [gen_server,<6853.186.0>,<6853.186.0>,'Elixir.GenStage',
             {'Elixir.Flow.MapReducer',
              {producer_consumer,
               [{subscribe_to,
                 [{<6853.188.0>,[{partition,0}]},
                  {<6853.189.0>,[{partition,0}]},
                  {<6853.190.0>,[{partition,0}]},
                  {<6853.191.0>,[{partition,0}]}]}],
               {0,4},
               #Fun<Elixir.Flow.Window.Global.2.31322697>,
               #Fun<Elixir.FlowLightning.1.121366654>,
               #Fun<Elixir.Flow.Materialize.3.45510982>}},
             []]]},
          {1495,465965,230883}},
         {<6853.193.0>,
          {proc_lib,init_p,
           [<6853.186.0>,
            [<6853.185.0>,<6853.175.0>,<6853.77.0>],
            gen,init_it,
            [gen_server,<6853.186.0>,<6853.186.0>,'Elixir.GenStage',
             {'Elixir.Flow.MapReducer',
              {producer_consumer,
               [{subscribe_to,
                 [{<6853.188.0>,[{partition,1}]},
                  {<6853.189.0>,[{partition,1}]},
                  {<6853.190.0>,[{partition,1}]},
                  {<6853.191.0>,[{partition,1}]}]}],
               {1,4},
               #Fun<Elixir.Flow.Window.Global.2.31322697>,
               #Fun<Elixir.FlowLightning.1.121366654>,
               #Fun<Elixir.Flow.Materialize.3.45510982>}},
             []]]},
          {1495,465965,231011}},
         {<6853.194.0>,
          {proc_lib,init_p,
           [<6853.186.0>,
            [<6853.185.0>,<6853.175.0>,<6853.77.0>],
            gen,init_it,
            [gen_server,<6853.186.0>,<6853.186.0>,'Elixir.GenStage',
             {'Elixir.Flow.MapReducer',
              {producer_consumer,
               [{subscribe_to,
                 [{<6853.188.0>,[{partition,2}]},
                  {<6853.189.0>,[{partition,2}]},
                  {<6853.190.0>,[{partition,2}]},
                  {<6853.191.0>,[{partition,2}]}]}],
               {2,4},
               #Fun<Elixir.Flow.Window.Global.2.31322697>,
               #Fun<Elixir.FlowLightning.1.121366654>,
               #Fun<Elixir.Flow.Materialize.3.45510982>}},
             []]]},
          {1495,465965,231123}},
         {<6853.195.0>,
          {proc_lib,init_p,
           [<6853.186.0>,
            [<6853.185.0>,<6853.175.0>,<6853.77.0>],
            gen,init_it,
            [gen_server,<6853.186.0>,<6853.186.0>,'Elixir.GenStage',
             {'Elixir.Flow.MapReducer',
              {producer_consumer,
               [{subscribe_to,
                 [{<6853.188.0>,[{partition,3}]},
                  {<6853.189.0>,[{partition,3}]},
                  {<6853.190.0>,[{partition,3}]},
                  {<6853.191.0>,[{partition,3}]}]}],
               {3,4},
               #Fun<Elixir.Flow.Window.Global.2.31322697>,
               #Fun<Elixir.FlowLightning.1.121366654>,
               #Fun<Elixir.Flow.Materialize.3.45510982>}},
             []]]},
          {1495,465965,231231}},
         {<6853.196.0>,
          {erlang,apply,[#Fun<Elixir.GenStage.13.64651076>,[]]},
          {1495,465965,231361}}]},
       {spawn_,true},
       {exit,[{<6853.176.0>,normal,{1495,465965,205064}}]},
       {exit_,true},
       {send,
        [{{code_server,<6853.175.0>},0,9},
         {{code_server,<6853.185.0>},0,2},
         {{code_server,<6853.186.0>},0,1},
         {{code_server,<6853.187.0>},0,3},
         {{code_server,<6853.188.0>},0,2},
         {{#Port<6853.674>,<6853.54.0>},2,6},
         {{#Port<6853.6204>,<6853.179.0>},1,0},
         {{#Port<6853.6217>,<6853.4.0>},1,0},
         {{#Port<6853.6218>,<6853.4.0>},1,0},
         {{#Port<6853.6219>,<6853.4.0>},1,0},
         {{#Port<6853.6220>,<6853.4.0>},1,0},
         {{#Port<6853.6221>,<6853.4.0>},1,0},
         {{#Port<6853.6222>,<6853.4.0>},1,0},
         {{#Port<6853.6223>,<6853.4.0>},1,0},
         {{#Port<6853.6224>,<6853.4.0>},1,0},
         {{#Port<6853.6225>,<6853.4.0>},1,0},
         {{#Port<6853.6226>,<6853.4.0>},1,0},
         {{#Port<6853.6227>,<6853.4.0>},1,0},
         {{#Port<6853.6228>,<6853.4.0>},1,0},
         {{#Port<6853.6229>,<6853.4.0>},1,0},
         {{#Port<6853.6230>,<6853.4.0>},1,0},
         {{#Port<6853.6231>,<6853.4.0>},1,0},
         {{#Port<6853.6232>,<6853.4.0>},1,0},
         {{#Port<6853.6233>,<6853.4.0>},1,0},
         {{#Port<6853.6234>,<6853.4.0>},1,0},
         {{#Port<6853.6235>,<6853.4.0>},1,0},
         {{#Port<6853.6236>,<6853.4.0>},1,0},
         {{#Port<6853.6237>,<6853.4.0>},1,0},
         {{#Port<6853.6238>,<6853.4.0>},1,0},
         {{#Port<6853.6239>,<6853.4.0>},1,0},
         {{#Port<6853.6240>,<6853.4.0>},1,0},
         {{#Port<6853.6241>,<6853.4.0>},1,0},
         {{#Port<6853.6242>,<6853.4.0>},1,0},
         {{#Port<6853.6243>,<6853.4.0>},1,0},
         {{#Port<6853.6244>,<6853.4.0>},1,0},
         {{#Port<6853.6245>,<6853.4.0>},1,0},
         {{#Port<6853.6246>,<6853.4.0>},1,0},
         {{#Port<6853.6247>,<6853.4.0>},1,0},
         {{#Port<6853.6248>,<6853.4.0>},1,0},
         {{#Port<6853.6249>,<6853.4.0>},1,0},
         {{#Port<6853.6250>,<6853.4.0>},1,0},
         {{#Port<6853.6251>,<6853.4.0>},1,0},
         {{#Port<6853.6252>,<6853.4.0>},1,0},
         {{#Port<6853.6253>,<6853.4.0>},1,0},
         {{#Port<6853.6254>,<6853.4.0>},1,0},
         {{#Port<6853.6255>,<6853.4.0>},1,0},
         {{#Port<6853.6256>,<6853.4.0>},1,0},
         {{#Port<6853.6257>,<6853.4.0>},1,0},
         {{#Port<6853.6258>,<6853.4.0>},1,0},
         {{#Port<6853.6259>,<6853.4.0>},1,0},
         {{#Port<6853.6260>,<6853.4.0>},1,0},
         {{#Port<6853.6261>,<6853.4.0>},1,0},
         {{#Port<6853.6262>,<6853.4.0>},1,0},
         {{#Port<6853.6263>,<6853.4.0>},1,0},
         {{#Port<6853.6264>,<6853.4.0>},1,0},
         {{#Port<6853.6265>,<6853.4.0>},1,0},
         {{#Port<6853.6266>,<6853.4.0>},1,0},
         {{#Port<6853.6267>,<6853.4.0>},1,0},
         {{#Port<6853.6268>,<6853.4.0>},1,0},
         {{#Port<6853.6269>,<6853.4.0>},1,0},
         {{#Port<6853.6270>,<6853.4.0>},1,0},
         {{#Port<6853.6271>,<6853.4.0>},1,0},
         {{#Port<6853.6272>,<6853.4.0>},1,0},
         {{#Port<6853.6273>,<6853.4.0>},1,0},
         {{#Port<6853.6274>,<6853.4.0>},1,0},
         {{#Port<6853.6275>,<6853.4.0>},1,0},
         {{#Port<6853.6276>,<6853.4.0>},1,0},
         {{#Port<6853.6277>,<6853.4.0>},1,0},
         {{#Port<6853.6278>,<6853.4.0>},1,0},
         {{#Port<6853.6279>,<6853.4.0>},1,0},
         {{#Port<6853.6280>,<6853.4.0>},1,0},
         {{#Port<6853.6281>,<6853.4.0>},1,0},
         {{#Port<6853.6282>,<6853.4.0>},1,0},
         {{#Port<6853.6283>,<6853.187.0>},52809,0},
         {{<6853.4.0>,<6853.36.0>},66,66},
         {{<6853.36.0>,<6853.175.0>},9,0},
         {{<6853.36.0>,<6853.185.0>},2,0},
         {{<6853.36.0>,<6853.186.0>},1,0},
         {{<6853.36.0>,<6853.187.0>},3,0},
         {{<6853.36.0>,<6853.188.0>},2,0},
         {{<6853.54.0>,<6853.56.0>},2,4},
         {{<6853.56.0>,<6853.176.0>},1,0},
         {{<6853.77.0>,<6853.175.0>},1,0},
         {{<6853.77.0>,<6853.176.0>},0,1},
         {{<6853.175.0>,<6853.185.0>},1,2},
         {{<6853.175.0>,<6853.187.0>},1,0},
         {{<6853.175.0>,<6853.196.0>},1,1},
         {{<6853.179.0>,<6853.184.0>},1,0},
         {{<6853.185.0>,<6853.186.0>},9,10},
         {{<6853.186.0>,<6853.187.0>},0,1},
         {{<6853.186.0>,<6853.188.0>},0,1},
         {{<6853.186.0>,<6853.189.0>},0,1},
         {{<6853.186.0>,<6853.190.0>},0,1},
         {{<6853.186.0>,<6853.191.0>},0,1},
         {{<6853.186.0>,<6853.192.0>},0,1},
         {{<6853.186.0>,<6853.193.0>},0,1},
         {{<6853.186.0>,<6853.194.0>},0,1},
         {{<6853.186.0>,<6853.195.0>},0,1},
         {{<6853.187.0>,<6853.188.0>},26,29},
         {{<6853.187.0>,<6853.189.0>},26,28},
         {{<6853.187.0>,<6853.190.0>},26,28},
         {{<6853.187.0>,<6853.191.0>},23,26},
         {{<6853.188.0>,<6853.192.0>},107,41},
         {{<6853.188.0>,<6853.193.0>},96,47},
         {{<6853.188.0>,<6853.194.0>},104,43},
         {{<6853.188.0>,<6853.195.0>},102,44},
         {{<6853.189.0>,<6853.192.0>},110,44},
         {{<6853.189.0>,<6853.193.0>},88,39},
         {{<6853.189.0>,<6853.194.0>},94,44},
         {{<6853.189.0>,<6853.195.0>},94,43},
         {{<6853.190.0>,<6853.192.0>},73,37},
         {{<6853.190.0>,<6853.193.0>},83,43},
         {{<6853.190.0>,<6853.194.0>},78,43},
         {{<6853.190.0>,<6853.195.0>},77,43},
         {{<6853.191.0>,<6853.192.0>},88,39},
         {{<6853.191.0>,<6853.193.0>},88,38},
         {{<6853.191.0>,<6853.194.0>},88,39},
         {{<6853.191.0>,<6853.195.0>},83,38},
         {{<6853.192.0>,<6853.196.0>},0,2},
         {{<6853.193.0>,<6853.196.0>},0,2},
         {{<6853.194.0>,<6853.196.0>},0,2},
         {{<6853.195.0>,<6853.196.0>},0,2}]},
       {send_,true},
       {send_self,[]},
       {send_self_,true},
       {'receive',
        [{#Port<6853.674>,6,61},
         {#Port<6853.6204>,1,12},
         {#Port<6853.6217>,2,25},
         {#Port<6853.6218>,2,25},
         {#Port<6853.6219>,2,25},
         {#Port<6853.6220>,2,25},
         {#Port<6853.6221>,2,25},
         {#Port<6853.6222>,2,25},
         {#Port<6853.6223>,2,25},
         {#Port<6853.6224>,2,25},
         {#Port<6853.6225>,2,25},
         {#Port<6853.6226>,2,25},
         {#Port<6853.6227>,2,25},
         {#Port<6853.6228>,2,25},
         {#Port<6853.6229>,2,25},
         {#Port<6853.6230>,2,25},
         {#Port<6853.6231>,2,25},
         {#Port<6853.6232>,2,25},
         {#Port<6853.6233>,2,25},
         {#Port<6853.6234>,2,25},
         {#Port<6853.6235>,2,25},
         {#Port<6853.6236>,2,25},
         {#Port<6853.6237>,2,25},
         {#Port<6853.6238>,2,25},
         {#Port<6853.6239>,2,25},
         {#Port<6853.6240>,2,25},
         {#Port<6853.6241>,2,25},
         {#Port<6853.6242>,2,25},
         {#Port<6853.6243>,2,25},
         {#Port<6853.6244>,2,25},
         {#Port<6853.6245>,2,25},
         {#Port<6853.6246>,2,25},
         {#Port<6853.6247>,2,25},
         {#Port<6853.6248>,2,25},
         {#Port<6853.6249>,2,25},
         {#Port<6853.6250>,2,25},
         {#Port<6853.6251>,2,25},
         {#Port<6853.6252>,2,25},
         {#Port<6853.6253>,2,25},
         {#Port<6853.6254>,2,25},
         {#Port<6853.6255>,2,25},
         {#Port<6853.6256>,2,25},
         {#Port<6853.6257>,2,25},
         {#Port<6853.6258>,2,25},
         {#Port<6853.6259>,2,25},
         {#Port<6853.6260>,2,25},
         {#Port<6853.6261>,2,25},
         {#Port<6853.6262>,2,25},
         {#Port<6853.6263>,2,25},
         {#Port<6853.6264>,2,25},
         {#Port<6853.6265>,2,25},
         {#Port<6853.6266>,2,25},
         {#Port<6853.6267>,2,25},
         {#Port<6853.6268>,2,25},
         {#Port<6853.6269>,2,25},
         {#Port<6853.6270>,2,25},
         {#Port<6853.6271>,2,25},
         {#Port<6853.6272>,2,25},
         {#Port<6853.6273>,2,25},
         {#Port<6853.6274>,2,25},
         {#Port<6853.6275>,2,25},
         {#Port<6853.6276>,2,25},
         {#Port<6853.6277>,2,25},
         {#Port<6853.6278>,2,25},
         {#Port<6853.6279>,2,25},
         {#Port<6853.6280>,2,25},
         {#Port<6853.6281>,2,25},
         {#Port<6853.6282>,2,25},
         {#Port<6853.6283>,52809,739326},
         {<6853.4.0>,198,13996},
         {<6853.36.0>,83,3499},
         {<6853.54.0>,6,203},
         {<6853.56.0>,2,20},
         {<6853.77.0>,1,10},
         {<6853.175.0>,13,418},
         {<6853.176.0>,1,13},
         {<6853.179.0>,1,3},
         {<6853.185.0>,13,110},
         {<6853.186.0>,19,1149},
         {<6853.187.0>,52924,1585733},
         {<6853.188.0>,203,110571},
         {<6853.189.0>,196,110494},
         {<6853.190.0>,192,110442},
         {<6853.191.0>,177,98256},
         {<6853.192.0>,380,826291},
         {<6853.193.0>,357,827477},
         {<6853.194.0>,366,825743},
         {<6853.195.0>,358,828007},
         {<6853.196.0>,1,6}]},
       {receive_,true},
       {trace,[]},
       {trace_,true}]}},
    [{epl_tracer,handle_info,2,[{file,"src/epl_tracer.erl"},{line,271}]},
     {gen_server,try_dispatch,4,[{file,"gen_server.erl"},{line,601}]},
     {gen_server,handle_msg,5,[{file,"gen_server.erl"},{line,667}]},
     {proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,247}]}]}
ERROR: timed out while collecting data from node
@arkgil
Copy link
Contributor

arkgil commented Jun 19, 2017

Hi @Arkham, thanks for bringing this up 🙂 I'll take a look at this. On a first glance, it definitely looks like an error on our side 😅

@arkgil arkgil self-assigned this Jun 19, 2017
@arkgil
Copy link
Contributor

arkgil commented Jun 20, 2017 •
edited
Loading

I've identified the issue.

Every 5 seconds, one of erlangpl's processes asks "spy" process on the remote node for data gathered for last 5 seconds:

%% apps/epl/src/epl_tracer.erl:231
RPid ! {Ref, self(), ...}

After that it waits for the response in receive block:

%% apps/epl/src/epl_tracer.erl:233-274
receive
    {Ref, ...} ->
after 5000 ->
      ?ERROR("timed out...")
end

This is why we see log message in the console: "ERROR: timed out...". The process crashes because "spy" process manages to send requested data back but after 5 seconds, when we are not in receive anymore, thus we get the message in handle_info, which is implemented like:

handle_info(Info, _State) ->
    exit({not_implemented, Info}).

So there is a slight race condition 😅 . I'm surprised it didn't come out earlier. Thanks once again @Arkham 🙂 👍

@OvermindDL1
Copy link

Still getting this in the latest version on the site:

** {{timeout,{gen_server,call,
                         ['[email protected]',{unsubscribe,<0.223.0>}]}},
    [{gen_server,call,2,[{file,"gen_server.erl"},{line,206}]},
     {epl,'-unsubscribe/0-lc$^0/1-0-',1,[{file,"src/epl.erl"},{line,72}]},
     {gen_server,try_terminate,3,[{file,"gen_server.erl"},{line,648}]},
     {gen_server,terminate,10,[{file,"gen_server.erl"},{line,833}]},
     {proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,247}]}]}
ERROR: timed out while collecting data from node
ERROR: timed out while collecting data from node
ERROR: timed out while collecting data from node
ERROR: timed out while collecting data from node
ERROR: timed out while collecting data from node
ERROR: timed out while collecting data from node
ERROR: timed out while collecting data from node
ERROR: timed out while collecting data from node
ERROR: timed out while collecting data from node

=ERROR REPORT==== 14-Aug-2017::08:40:23 ===
** Generic server '[email protected]' terminating
** Last message in was timeout
** When Server state == {state,[<0.231.0>,<0.218.0>,<0.110.0>,<0.109.0>,
                                <0.108.0>],
                               #Ref<0.2322663479.1295253506.33638>,
                               <7310.27986.10>,11}
** Reason for termination ==
** {bad_return_value,{stop,{max_timeout,'[email protected]'}}}

@tomazbracic
Copy link

Me too, as of today. :/

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees

@arkgil arkgil

Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
4 participants
@Arkham @OvermindDL1 @tomazbracic @arkgil