Exception During Aggregation in a stream udf

Feature Discussion Aggregation
1

Hi,

I have a big problem during my stream udf, in particular during its execution I receive this two type of errors:

a) WARNING (scan): (scan.c::380) send error - fd 100 rv -1 Broken pipe

b) WARNING (scan): (scan.c::380) send error - fd 100 rv -1 Connection reset by peer

I think this errors are similar, but I don’t understand their meaning. I have just googled but I have not found any solutions or news. The problem is that if I debug stream udf it seem work in fact the results are correct and complete but it come back to client JAVA with this error:

**`ERROR 23938 --- [nio-9080-exec-1] o.a.c.c.C.[.[.[/].[dispatcherServlet]    : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is com.aerospike.client.AerospikeException: org.luaj.vm2.LuaError: aerospike:160 function not found**
**stack traceback:**
**    [Java]: in ?] with root cause**

org.luaj.vm2.LuaError: aerospike:160 function not found
stack traceback:
    [Java]: in ?
    at org.luaj.vm2.lib.BaseLib$error.call(Unknown Source)
    at org.luaj.vm2.LuaClosure.execute(Unknown Source)
    at org.luaj.vm2.LuaClosure.onInvoke(Unknown Source)
    at org.luaj.vm2.LuaClosure.invoke(Unknown Source)
    at org.luaj.vm2.LuaValue.invoke(Unknown Source)
    at com.aerospike.client.lua.LuaInstance.call(LuaInstance.java:128)
    at com.aerospike.client.query.QueryAggregateExecutor.runThreads(QueryAggregateExecutor.java:104)
    at com.aerospike.client.query.QueryAggregateExecutor.run(QueryAggregateExecutor.java:77)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)

2016-06-23 16:21:55.901 ERROR 23938 --- [nio-9080-exec-1] o.s.b.actuate.web.BasicErrorController   : com.aerospike.client.AerospikeException: org.luaj.vm2.LuaError: aerospike:160 function not found
stack traceback:
    [Java]: in ?`

While AEROSPIKE LOG shows:

Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) '''''''''''''''''''''''' searchSSD received threshold: 260860
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) '''''''''''''''''''''' RESULT USER: alessandro
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) ------------------------ CAMERA samsung-s4_luca
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) '''''''''''''''''''''' RESULT CAMERA: samsung-s7_alessandro
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) '''''''''''''''''''''' RESULT HAMMING: 262579
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::175) AGGREGATE
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) ''''''''''''''''' HAMMING FOR samsung-s4_luca is 262232
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) '''''''''''''''''''''' RESULT USER: luca
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) '''''''''''''''''''''' RESULT CAMERA: samsung-s4_luca
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) '''''''''''''''''''''' RESULT HAMMING: 262232
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::175) AGGREGATE
Jun 23 2016 14:21:03 GMT: INFO (aggr): ([C]::-1) ##### ##### stream searchcamera received threshold: 260860
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) '''''''''''''''''''''''' searchSSD received threshold: 260860
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) ------------------------ CAMERA note3_alessandro
Jun 23 2016 14:21:03 GMT: INFO (aggr): ([C]::-1) ##### ##### stream searchcamera received threshold: 260860
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) '''''''''''''''''''''''' searchSSD received threshold: 260860
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) ------------------------ CAMERA TabS_alessandro
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) ''''''''''''''''' HAMMING FOR note3_alessandro is 261795
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) '''''''''''''''''''''' RESULT USER: alessandro
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) '''''''''''''''''''''' RESULT CAMERA: note3_alessandro
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::80) '''''''''''''''''''''' RESULT HAMMING: 261795
Jun 23 2016 14:21:03 GMT: INFO (aggr): (/opt/aerospike/sys/udf/lua/stream_ops.lua::175) AGGREGATE
**

Jun 23 2016 14:21:03 GMT: WARNING (scan): (scan.c::380) send error - fd 100 rv -1 Connection reset by peer

** or

Jun 23 2016 14:21:03 GMT:WARNING (scan): (scan.c::380) send error - fd 100 rv -1 Broken pipe

I hope someone reply not with solution but at least with explanation of these errors.