· 7 years ago · Jan 15, 2019, 08:00 PM
1administrator@aegis:~$ sudo docker run -d --log-opt max-size=100m --log-opt max-file=5 \
2> -v /home/administrator/aegis/aegis_host_os_ip_address.txt:/data/host_os_ip_address:ro \
3> -v /home/administrator/aegis/aegis_host_os_hostname.txt:/data/host_os_hostname:ro \
4> --restart='unless-stopped' --name=data-aggregator -p 5555-5557:5555-5557 -p 8113:8113 \
5> registry.gitlab.com/changedynamix/aggregator/c376:dev --host 0.0.0.0 --port 5555 --batchTime 60 --dns 8.8.8.8 \
6> --receiver http://172.16.4.214:8080 --uniqueId monitoring-system-aggregator-bohdana \
7> --monitoring https://01rlymokc5.execute-api.us-west-2.amazonaws.com/qa \
8> --apiKey 88d335d9c18902fee2080dac63638b5139c4b7a78d78e8874528d204 \
9> --secretKey 693F66214F327A76785550413A5E253C3E6D70657A217B4155407A666A305876477B68495A2F5D36 \
10> --publicKey 5A5832576F434D2D57367D667148464865326E3C4B74586B733C574C7A624E6355642D5239282E72 \
11> --description "Aggregator for testing of the monitoring system"
120cefb8e62ba16821ca9c0b51e9351dc93de8fdc320d64dbe4f8402bad61a82c9
13administrator@aegis:~$
14administrator@aegis:~$
15administrator@aegis:~$ sudo docker ps
16CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES
170cefb8e62ba1 registry.gitlab.com/changedynamix/aggregator/c376:dev "/opt/docker/runit.s…" 5 seconds ago Up 4 seconds 0.0.0.0:5555-5557->5555-5557/tcp, 0.0.0.0:8113->8113/tcp data-aggregator
18e3762395d755 changedynamix/network-monitor:latest "/monitor.sh -i ens1…" About an hour ago Up About an hour network-monitor
19administrator@aegis:~$
20administrator@aegis:~$
21administrator@aegis:~$
22administrator@aegis:~$ docker exec -it data-aggregator sh -c "tail -f -n +1 /etc/sv/aegis-aggregator/logs/aggregator.log.json"
23{"@timestamp":"2019-01-15T19:54:47.980+00:00","@version":1,"message":"Slf4jLogger started","logger_name":"akka.event.slf4j.Slf4jLogger","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-2","level":"INFO","level_value":20000}
24{"@timestamp":"2019-01-15T19:54:48.077+00:00","@version":1,"message":"command-line configuration accepted:\n configFileName = None\n host = Some(0.0.0.0)\n port = Some(5555)\n shutdownPort = None\n batchTimeSeconds = Some(60)\n receiverUrl = Some(http://172.16.4.214:8080)\n commandsUrl = Some(http://172.16.4.214:8080/commands)\n commandsPollIntervalSeconds = None\n uniqueId = Some(monitoring-system-aggregator-bohdana)\n descriptionOpt = Some(Aggregator for testing of the monitoring system)\n keepTempFiles = None\n logLevelOpt = None\n prometheusPushGateway = None\n monitoring = Some(https://01rlymokc5.execute-api.us-west-2.amazonaws.com/qa)\n parallelism = None\n hostnameCacheTtl = None\n ldapCacheTtl = None\n retriesDuration = None\n maxRetriesCount = None\n ldapDomain = None\n ldapServer = None\n ldapBase = None\n ldapMaxRequests = None\n\n\n","logger_name":"akka.actor.ActorSystemImpl","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-2","level":"INFO","level_value":20000,"sourceThread":"main","akkaSource":"akka.actor.ActorSystemImpl(aegis-aggregator)","sourceActorSystem":"aegis-aggregator","akkaTimestamp":"19:54:48.074UTC"}
25{"@timestamp":"2019-01-15T19:54:48.089+00:00","@version":1,"message":"Merged configuration:\n zmqEndpoint = tcp://0.0.0.0:5555\n receiverUrl = http://172.16.4.214:8080\n parallelism = 10\n monitoring = Some(https://01rlymokc5.execute-api.us-west-2.amazonaws.com/qa)\n commandsDistributionInterface = 0.0.0.0\n commandsDistributionPort = 8113\n batchTimeSeconds = 60\n zmqHost = 0.0.0.0\n zmqPort = 5555\n zmqShutdownPort = 5557\n zmqShutdownEndpoint = tcp://0.0.0.0:5557\n commandsUrl = http://172.16.4.214:8080/commands\n commandsPollingIntervalSeconds = 60\n keepTempFiles = false\n uniqueId = monitoring-system-aggregator-bohdana\n descriptionOpt = Some(Aggregator for testing of the monitoring system)\n hostnameCacheTtl = 3600\n ldapCacheTtl = 86400\n retriesDuration = 3600\n maxRetriesCount = 10\n prometheusPushGateway = None\n ldapDomain = \n ldapServer = \n ldapBase = \n ldapMaxRequests = 1\n failedDir = /etc/sv/aegis-aggregator/failed_uploads\n shutdownTimeouts = Config(SimpleConfigObject({\"delivery\":10,\"packing\":15}))\n\n","logger_name":"akka.actor.ActorSystemImpl","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-2","level":"INFO","level_value":20000,"sourceThread":"main","akkaTimestamp":"19:54:48.089UTC","akkaSource":"akka.actor.ActorSystemImpl(aegis-aggregator)","sourceActorSystem":"aegis-aggregator"}
26{"@timestamp":"2019-01-15T19:54:51.576+00:00","@version":1,"message":"Tested receiver connectivity: OK","logger_name":"Connectivity tester","thread_name":"main","level":"INFO","level_value":20000}
27{"@timestamp":"2019-01-15T19:54:51.576+00:00","@version":1,"message":"Tested receiver connectivity: OK","logger_name":"Connectivity tester","thread_name":"main","level":"INFO","level_value":20000}
28{"@timestamp":"2019-01-15T19:54:51.576+00:00","@version":1,"message":"Tested DNS connectivity: OK","logger_name":"Connectivity tester","thread_name":"main","level":"INFO","level_value":20000}
29{"@timestamp":"2019-01-15T19:54:51.576+00:00","@version":1,"message":"Tested DNS connectivity: OK","logger_name":"Connectivity tester","thread_name":"main","level":"INFO","level_value":20000}
30{"@timestamp":"2019-01-15T19:54:51.586+00:00","@version":1,"message":"accepting shutdown requests on tcp://0.0.0.0:5557","logger_name":"com.sageaxcess.aegisaggregator.actors.ShutdownListener","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-16","level":"INFO","level_value":20000,"sourceThread":"aegis-aggregator-akka.actor.default-dispatcher-4","akkaSource":"ShutdownListener(akka://aegis-aggregator)","sourceActorSystem":"aegis-aggregator","akkaTimestamp":"19:54:51.586UTC"}
31{"@timestamp":"2019-01-15T19:54:51.586+00:00","@version":1,"message":"accepting shutdown requests on tcp://0.0.0.0:5557","logger_name":"com.sageaxcess.aegisaggregator.actors.ShutdownListener","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-16","level":"INFO","level_value":20000,"sourceThread":"aegis-aggregator-akka.actor.default-dispatcher-4","akkaSource":"ShutdownListener(akka://aegis-aggregator)","sourceActorSystem":"aegis-aggregator","akkaTimestamp":"19:54:51.586UTC"}
32{"@timestamp":"2019-01-15T19:54:51.842+00:00","@version":1,"message":"ZMQ PULL socket bound to tcp://0.0.0.0:5555","logger_name":"ZMQ Source","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-16","level":"INFO","level_value":20000}
33{"@timestamp":"2019-01-15T19:54:51.842+00:00","@version":1,"message":"ZMQ PULL socket bound to tcp://0.0.0.0:5555","logger_name":"ZMQ Source","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-16","level":"INFO","level_value":20000}
34{"@timestamp":"2019-01-15T19:54:51.990+00:00","@version":1,"message":"proto-packer error","logger_name":"akka.actor.ActorSystemImpl","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-2","level":"ERROR","level_value":40000,"stack_trace":"java.lang.RuntimeException: Message, hex encoded:\n1400000010001e000800140000000c0007001000100000000000000c90000000480100003400000041669a698e0fd74100002600540030000000040008000c001000380040004800140018001c002000240028002c000000260000006e0f0000690400006a1f000069040000d40000009c000000780000006c0000005c00000044000000cc050000ecad58f7911c3a40000000c0a78f33400000000014550f40000000800a4a2f40000000001200000030303030303030303030303030303030303000000e0000003139322e3136382e35322e31323800000500000061656769730000000000000000000000180000006c696270636170302e383a616d643634a3312e372e342d32000000002e000000322e342e342d3230206275696c642061742053756e204a616e2031332031383a33353a343120555443203230313900002100000028446f636b657229205562756e74752031362e30342e35204c5453204c696e7578000000290000006d6f6e69746f72696e672d73797374656d2d6e6574776f726b2d6d6f6e69746f722d626f6864616e61000000\ncannot be repacked, dropped.\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:56)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$.$anonfun$packerFlow$1(ProtoPacker.scala:476)\n\tat akka.stream.impl.fusing.Map$$anon$9.onPush(Ops.scala:51)\n\tat akka.stream.impl.fusing.GraphInterpreter.processPush(GraphInterpreter.scala:519)\n\tat akka.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:411)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:588)\n\tat akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:472)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:563)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:745)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:760)\n\tat akka.actor.Actor.aroundReceive(Actor.scala:517)\n\tat akka.actor.Actor.aroundReceive$(Actor.scala:515)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:670)\n\tat akka.actor.ActorCell.receiveMessage(ActorCell.scala:588)\n\tat akka.actor.ActorCell.invoke(ActorCell.scala:557)\n\tat akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)\n\tat akka.dispatch.Mailbox.run(Mailbox.scala:225)\n\tat akka.dispatch.Mailbox.exec(Mailbox.scala:235)\n\tat akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)\n\tat akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)\n\tat akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)\n\tat akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)\nCaused by: java.lang.Error: java.nio.charset.MalformedInputException: Input length = 1\n\tat com.google.flatbuffers.Table.__string(Table.java:125)\n\tat com.sageaxcess.flatbuffer.SystemStatsData.pcapVersion(SystemStatsData.java:29)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$SystemStatsPacker.packSpecific(ProtoPacker.scala:393)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.flat2proto(ProtoPacker.scala:78)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:48)\n\t... 21 common frames omitted\nCaused by: java.nio.charset.MalformedInputException: Input length = 1\n\tat java.nio.charset.CoderResult.throwException(CoderResult.java:281)\n\tat com.google.flatbuffers.Table.__string(Table.java:122)\n\t... 25 common frames omitted\n","sourceThread":"aegis-aggregator-akka.actor.default-dispatcher-20","akkaTimestamp":"19:54:51.984UTC","akkaSource":"akka.actor.ActorSystemImpl(aegis-aggregator)","sourceActorSystem":"aegis-aggregator"}
35{"@timestamp":"2019-01-15T19:54:51.992+00:00","@version":1,"message":"proto-packer error","logger_name":"akka.actor.ActorSystemImpl","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-2","level":"ERROR","level_value":40000,"stack_trace":"java.lang.RuntimeException: Message, hex encoded:\n1400000010001e000800140000000c0007001000100000000000000c900000004801000034000000b62bdb718e0fd74100002600540030000000040008000c001000380040004800140018001c002000240028002c000000260000006e0f0000690400006a1f000069040000d40000009c000000780000006c0000005c00000044000000cc0500000edbf9515c163940000000c0a78f33400000000016550f40000000000a4a2f40000000001200000030303030303030303030303030303030303000000e0000003139322e3136382e35322e31323800000500000061656769730000000000000000000000180000006c696270636170302e383a616d643634a5312e372e342d32000000002e000000322e342e342d3230206275696c642061742053756e204a616e2031332031383a33353a343120555443203230313900002100000028446f636b657229205562756e74752031362e30342e35204c5453204c696e7578000000290000006d6f6e69746f72696e672d73797374656d2d6e6574776f726b2d6d6f6e69746f722d626f6864616e61000000\ncannot be repacked, dropped.\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:56)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$.$anonfun$packerFlow$1(ProtoPacker.scala:476)\n\tat akka.stream.impl.fusing.Map$$anon$9.onPush(Ops.scala:51)\n\tat akka.stream.impl.fusing.GraphInterpreter.processPush(GraphInterpreter.scala:519)\n\tat akka.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:411)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:588)\n\tat akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:472)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:563)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:745)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:760)\n\tat akka.actor.Actor.aroundReceive(Actor.scala:517)\n\tat akka.actor.Actor.aroundReceive$(Actor.scala:515)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:670)\n\tat akka.actor.ActorCell.receiveMessage(ActorCell.scala:588)\n\tat akka.actor.ActorCell.invoke(ActorCell.scala:557)\n\tat akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)\n\tat akka.dispatch.Mailbox.run(Mailbox.scala:225)\n\tat akka.dispatch.Mailbox.exec(Mailbox.scala:235)\n\tat akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)\n\tat akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)\n\tat akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)\n\tat akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)\nCaused by: java.lang.Error: java.nio.charset.MalformedInputException: Input length = 1\n\tat com.google.flatbuffers.Table.__string(Table.java:125)\n\tat com.sageaxcess.flatbuffer.SystemStatsData.pcapVersion(SystemStatsData.java:29)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$SystemStatsPacker.packSpecific(ProtoPacker.scala:393)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.flat2proto(ProtoPacker.scala:78)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:48)\n\t... 21 common frames omitted\nCaused by: java.nio.charset.MalformedInputException: Input length = 1\n\tat java.nio.charset.CoderResult.throwException(CoderResult.java:281)\n\tat com.google.flatbuffers.Table.__string(Table.java:122)\n\t... 25 common frames omitted\n","sourceThread":"aegis-aggregator-akka.actor.default-dispatcher-20","akkaTimestamp":"19:54:51.990UTC","akkaSource":"akka.actor.ActorSystemImpl(aegis-aggregator)","sourceActorSystem":"aegis-aggregator"}
36{"@timestamp":"2019-01-15T19:54:51.997+00:00","@version":1,"message":"proto-packer error","logger_name":"akka.actor.ActorSystemImpl","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-2","level":"ERROR","level_value":40000,"stack_trace":"java.lang.RuntimeException: Message, hex encoded:\n1400000010001e000800140000000c0007001000100000000000000c900000004801000034000000024507888e0fd74100002600540030000000040008000c001000380040004800140018001c002000240028002c000000260000006e0f0000680400006a1f000068040000d40000009c000000780000006c0000005c00000044000000cc050000af6dc171d7903940000000c0a78f3340000000008a540f40000000002d4a2f40000000001200000030303030303030303030303030303030303000000e0000003139322e3136382e35322e31323800000500000061656769730000000000000000000000180000006c696270636170302e383a616d643634a7312e372e342d32000000002e000000322e342e342d3230206275696c642061742053756e204a616e2031332031383a33353a343120555443203230313900002100000028446f636b657229205562756e74752031362e30342e35204c5453204c696e7578000000290000006d6f6e69746f72696e672d73797374656d2d6e6574776f726b2d6d6f6e69746f722d626f6864616e61000000\ncannot be repacked, dropped.\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:56)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$.$anonfun$packerFlow$1(ProtoPacker.scala:476)\n\tat akka.stream.impl.fusing.Map$$anon$9.onPush(Ops.scala:51)\n\tat akka.stream.impl.fusing.GraphInterpreter.processPush(GraphInterpreter.scala:519)\n\tat akka.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:411)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:588)\n\tat akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:472)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:563)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:745)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:760)\n\tat akka.actor.Actor.aroundReceive(Actor.scala:517)\n\tat akka.actor.Actor.aroundReceive$(Actor.scala:515)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:670)\n\tat akka.actor.ActorCell.receiveMessage(ActorCell.scala:588)\n\tat akka.actor.ActorCell.invoke(ActorCell.scala:557)\n\tat akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)\n\tat akka.dispatch.Mailbox.run(Mailbox.scala:225)\n\tat akka.dispatch.Mailbox.exec(Mailbox.scala:235)\n\tat akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)\n\tat akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)\n\tat akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)\n\tat akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)\nCaused by: java.lang.Error: java.nio.charset.MalformedInputException: Input length = 1\n\tat com.google.flatbuffers.Table.__string(Table.java:125)\n\tat com.sageaxcess.flatbuffer.SystemStatsData.pcapVersion(SystemStatsData.java:29)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$SystemStatsPacker.packSpecific(ProtoPacker.scala:393)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.flat2proto(ProtoPacker.scala:78)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:48)\n\t... 21 common frames omitted\nCaused by: java.nio.charset.MalformedInputException: Input length = 1\n\tat java.nio.charset.CoderResult.throwException(CoderResult.java:281)\n\tat com.google.flatbuffers.Table.__string(Table.java:122)\n\t... 25 common frames omitted\n","sourceThread":"aegis-aggregator-akka.actor.default-dispatcher-20","akkaTimestamp":"19:54:51.993UTC","akkaSource":"akka.actor.ActorSystemImpl(aegis-aggregator)","sourceActorSystem":"aegis-aggregator"}
37{"@timestamp":"2019-01-15T19:54:52.052+00:00","@version":1,"message":"proto-packer error","logger_name":"akka.actor.ActorSystemImpl","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-21","level":"ERROR","level_value":40000,"stack_trace":"java.lang.RuntimeException: Message, hex encoded:\n1400000010001e000800140000000c0007001000100000000000000c900000004801000034000000e4493f808e0fd74100002600540030000000040008000c001000380040004800140018001c002000240028002c000000260000006e0f0000690400006a1f000069040000d40000009c000000780000006c0000005c00000044000000cc0500002ec528759c473940000000c0a78f33400000000018550f4000000080094a2f40000000001200000030303030303030303030303030303030303000000e0000003139322e3136382e35322e31323800000500000061656769730000000000000000000000180000006c696270636170302e383a616d643634a5312e372e342d32000000002e000000322e342e342d3230206275696c642061742053756e204a616e2031332031383a33353a343120555443203230313900002100000028446f636b657229205562756e74752031362e30342e35204c5453204c696e7578000000290000006d6f6e69746f72696e672d73797374656d2d6e6574776f726b2d6d6f6e69746f722d626f6864616e61000000\ncannot be repacked, dropped.\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:56)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$.$anonfun$packerFlow$1(ProtoPacker.scala:476)\n\tat akka.stream.impl.fusing.Map$$anon$9.onPush(Ops.scala:51)\n\tat akka.stream.impl.fusing.GraphInterpreter.processPush(GraphInterpreter.scala:519)\n\tat akka.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:411)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:588)\n\tat akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:472)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:563)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:745)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:760)\n\tat akka.actor.Actor.aroundReceive(Actor.scala:517)\n\tat akka.actor.Actor.aroundReceive$(Actor.scala:515)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:670)\n\tat akka.actor.ActorCell.receiveMessage(ActorCell.scala:588)\n\tat akka.actor.ActorCell.invoke(ActorCell.scala:557)\n\tat akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)\n\tat akka.dispatch.Mailbox.run(Mailbox.scala:225)\n\tat akka.dispatch.Mailbox.exec(Mailbox.scala:235)\n\tat akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)\n\tat akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)\n\tat akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)\n\tat akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)\nCaused by: java.lang.Error: java.nio.charset.MalformedInputException: Input length = 1\n\tat com.google.flatbuffers.Table.__string(Table.java:125)\n\tat com.sageaxcess.flatbuffer.SystemStatsData.pcapVersion(SystemStatsData.java:29)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$SystemStatsPacker.packSpecific(ProtoPacker.scala:393)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.flat2proto(ProtoPacker.scala:78)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:48)\n\t... 21 common frames omitted\nCaused by: java.nio.charset.MalformedInputException: Input length = 1\n\tat java.nio.charset.CoderResult.throwException(CoderResult.java:281)\n\tat com.google.flatbuffers.Table.__string(Table.java:122)\n\t... 25 common frames omitted\n","sourceThread":"aegis-aggregator-akka.actor.default-dispatcher-20","akkaSource":"akka.actor.ActorSystemImpl(aegis-aggregator)","sourceActorSystem":"aegis-aggregator","akkaTimestamp":"19:54:52.025UTC"}
38{"@timestamp":"2019-01-15T19:54:52.055+00:00","@version":1,"message":"proto-packer error","logger_name":"akka.actor.ActorSystemImpl","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-21","level":"ERROR","level_value":40000,"stack_trace":"java.lang.RuntimeException: Message, hex encoded:\n1400000010001e000800140000000c0007001000100000000000000c900000004801000034000000863c23918e0fd74100002600540030000000040008000c001000380040004800140018001c002000240028002c000000260000006e0f0000670400006a1f000067040000d40000009c000000780000006c0000005c00000044000000cc050000ee78633d07213940000000c0a78f3340000000008c540f40000000802c4a2f40000000001200000030303030303030303030303030303030303000000e0000003139322e3136382e35322e31323800000500000061656769730000000000000000000000180000006c696270636170302e383a616d643634a9312e372e342d32000000002e000000322e342e342d3230206275696c642061742053756e204a616e2031332031383a33353a343120555443203230313900002100000028446f636b657229205562756e74752031362e30342e35204c5453204c696e7578000000290000006d6f6e69746f72696e672d73797374656d2d6e6574776f726b2d6d6f6e69746f722d626f6864616e61000000\ncannot be repacked, dropped.\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:56)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$.$anonfun$packerFlow$1(ProtoPacker.scala:476)\n\tat akka.stream.impl.fusing.Map$$anon$9.onPush(Ops.scala:51)\n\tat akka.stream.impl.fusing.GraphInterpreter.processPush(GraphInterpreter.scala:519)\n\tat akka.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:411)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:588)\n\tat akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:472)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:563)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:745)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:760)\n\tat akka.actor.Actor.aroundReceive(Actor.scala:517)\n\tat akka.actor.Actor.aroundReceive$(Actor.scala:515)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:670)\n\tat akka.actor.ActorCell.receiveMessage(ActorCell.scala:588)\n\tat akka.actor.ActorCell.invoke(ActorCell.scala:557)\n\tat akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)\n\tat akka.dispatch.Mailbox.run(Mailbox.scala:225)\n\tat akka.dispatch.Mailbox.exec(Mailbox.scala:235)\n\tat akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)\n\tat akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)\n\tat akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)\n\tat akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)\nCaused by: java.lang.Error: java.nio.charset.MalformedInputException: Input length = 1\n\tat com.google.flatbuffers.Table.__string(Table.java:125)\n\tat com.sageaxcess.flatbuffer.SystemStatsData.pcapVersion(SystemStatsData.java:29)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$SystemStatsPacker.packSpecific(ProtoPacker.scala:393)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.flat2proto(ProtoPacker.scala:78)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:48)\n\t... 21 common frames omitted\nCaused by: java.nio.charset.MalformedInputException: Input length = 1\n\tat java.nio.charset.CoderResult.throwException(CoderResult.java:281)\n\tat com.google.flatbuffers.Table.__string(Table.java:122)\n\t... 25 common frames omitted\n","sourceThread":"aegis-aggregator-akka.actor.default-dispatcher-23","akkaTimestamp":"19:54:52.032UTC","akkaSource":"akka.actor.ActorSystemImpl(aegis-aggregator)","sourceActorSystem":"aegis-aggregator"}
39{"@timestamp":"2019-01-15T19:54:55.230+00:00","@version":1,"message":"Register aggregator: OK","logger_name":"Registering","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-2","level":"INFO","level_value":20000}
40{"@timestamp":"2019-01-15T19:54:55.230+00:00","@version":1,"message":"Register aggregator: OK","logger_name":"Registering","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-2","level":"INFO","level_value":20000}
41{"@timestamp":"2019-01-15T19:54:58.000+00:00","@version":1,"message":"Send aggregator heartbeat: OK","logger_name":"com.sageaxcess.aegisaggregator.monitoring.Heartbeats$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-18","level":"INFO","level_value":20000}
42{"@timestamp":"2019-01-15T19:55:02.342+00:00","@version":1,"message":"Accepted the new command for distribution: {\"command\": \"update_setting\", \"name\": \"process.priority\", \"value\": \"-10\"}","logger_name":"com.sageaxcess.aegisaggregator.commands.CommandsDistributor$CommandsActor","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-3","level":"INFO","level_value":20000,"sourceThread":"aegis-aggregator-akka.actor.default-dispatcher-3","akkaSource":"akka://aegis-aggregator/user/$b","sourceActorSystem":"aegis-aggregator","akkaTimestamp":"19:55:02.342UTC"}
43{"@timestamp":"2019-01-15T19:55:02.848+00:00","@version":1,"message":"Unresolvable IP, \nIP hex: effffffa\n ","logger_name":"com.sageaxcess.aegisaggregator.stream.HostnameResolver$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-20","level":"DEBUG","level_value":10000}
44{"@timestamp":"2019-01-15T19:55:05.029+00:00","@version":1,"message":"Unresolvable IP, \nIP hex: 688335fc\n ","logger_name":"com.sageaxcess.aegisaggregator.stream.HostnameResolver$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-20","level":"DEBUG","level_value":10000}
45{"@timestamp":"2019-01-15T19:55:07.206+00:00","@version":1,"message":"Unresolvable IP, \nIP hex: effffffa\n ","logger_name":"com.sageaxcess.aegisaggregator.stream.HostnameResolver$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-20","level":"DEBUG","level_value":10000}
46{"@timestamp":"2019-01-15T19:55:07.249+00:00","@version":1,"message":"Unresolvable IP, \nIP hex: fe800000000000004549f05276ce8586\n ","logger_name":"com.sageaxcess.aegisaggregator.stream.HostnameResolver$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-16","level":"DEBUG","level_value":10000}
47{"@timestamp":"2019-01-15T19:55:09.425+00:00","@version":1,"message":"Unresolvable IP, \nIP hex: ff020000000000000000000000010003\n ","logger_name":"com.sageaxcess.aegisaggregator.stream.HostnameResolver$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-16","level":"DEBUG","level_value":10000}
48{"@timestamp":"2019-01-15T19:55:13.765+00:00","@version":1,"message":"Unresolvable IP, \nIP hex: 0ca79701\n ","logger_name":"com.sageaxcess.aegisaggregator.stream.HostnameResolver$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-20","level":"DEBUG","level_value":10000}
49{"@timestamp":"2019-01-15T19:55:15.944+00:00","@version":1,"message":"Unresolvable IP, \nIP hex: 6bb5bfbd\n ","logger_name":"com.sageaxcess.aegisaggregator.stream.HostnameResolver$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-20","level":"DEBUG","level_value":10000}
50{"@timestamp":"2019-01-15T19:55:22.558+00:00","@version":1,"message":"Unresolvable IP, \nIP hex: 45c39f9e\n ","logger_name":"com.sageaxcess.aegisaggregator.stream.HostnameResolver$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-20","level":"DEBUG","level_value":10000}
51{"@timestamp":"2019-01-15T19:55:26.403+00:00","@version":1,"message":"Send collector 'monitoring-system-network-monitor-bohdana' heartbeat: OK","logger_name":"com.sageaxcess.aegisaggregator.monitoring.Heartbeats$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-3","level":"INFO","level_value":20000}
52{"@timestamp":"2019-01-15T19:55:26.916+00:00","@version":1,"message":"Unresolvable IP, \nIP hex: d8060246\n ","logger_name":"com.sageaxcess.aegisaggregator.stream.HostnameResolver$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-20","level":"DEBUG","level_value":10000}
53{"@timestamp":"2019-01-15T19:55:26.923+00:00","@version":1,"message":"proto-packer error","logger_name":"akka.actor.ActorSystemImpl","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-21","level":"ERROR","level_value":40000,"stack_trace":"java.lang.RuntimeException: Message, hex encoded:\n1400000010001e000800140000000c0007001000100000000000000c900000004801000034000000cc08de998e0fd74100002600540030000000040008000c001000380040004800140018001c002000240028002c000000260000006e0f0000670400006a1f000067040000d40000009c000000780000006c0000005c00000044000000cc050000feaca7f7d96d3940000000c0a78f3340000000008e540f40000000002c4a2f40000000001200000030303030303030303030303030303030303000000e0000003139322e3136382e35322e31323800000500000061656769730000000000000000000000180000006c696270636170302e383a616d643634a9312e372e342d32000000002e000000322e342e342d3230206275696c642061742053756e204a616e2031332031383a33353a343120555443203230313900002100000028446f636b657229205562756e74752031362e30342e35204c5453204c696e7578000000290000006d6f6e69746f72696e672d73797374656d2d6e6574776f726b2d6d6f6e69746f722d626f6864616e61000000\ncannot be repacked, dropped.\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:56)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$.$anonfun$packerFlow$1(ProtoPacker.scala:476)\n\tat akka.stream.impl.fusing.Map$$anon$9.onPush(Ops.scala:51)\n\tat akka.stream.impl.fusing.GraphInterpreter.processPush(GraphInterpreter.scala:519)\n\tat akka.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:411)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:588)\n\tat akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:472)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:563)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:745)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:760)\n\tat akka.actor.Actor.aroundReceive(Actor.scala:517)\n\tat akka.actor.Actor.aroundReceive$(Actor.scala:515)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:670)\n\tat akka.actor.ActorCell.receiveMessage(ActorCell.scala:588)\n\tat akka.actor.ActorCell.invoke(ActorCell.scala:557)\n\tat akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)\n\tat akka.dispatch.Mailbox.run(Mailbox.scala:225)\n\tat akka.dispatch.Mailbox.exec(Mailbox.scala:235)\n\tat akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)\n\tat akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)\n\tat akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)\n\tat akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)\nCaused by: java.lang.Error: java.nio.charset.MalformedInputException: Input length = 1\n\tat com.google.flatbuffers.Table.__string(Table.java:125)\n\tat com.sageaxcess.flatbuffer.SystemStatsData.pcapVersion(SystemStatsData.java:29)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$SystemStatsPacker.packSpecific(ProtoPacker.scala:393)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.flat2proto(ProtoPacker.scala:78)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:48)\n\t... 21 common frames omitted\nCaused by: java.nio.charset.MalformedInputException: Input length = 1\n\tat java.nio.charset.CoderResult.throwException(CoderResult.java:281)\n\tat com.google.flatbuffers.Table.__string(Table.java:122)\n\t... 25 common frames omitted\n","sourceThread":"aegis-aggregator-akka.actor.default-dispatcher-16","akkaTimestamp":"19:55:26.919UTC","akkaSource":"akka.actor.ActorSystemImpl(aegis-aggregator)","sourceActorSystem":"aegis-aggregator"}
54{"@timestamp":"2019-01-15T19:55:26.928+00:00","@version":1,"message":"proto-packer error","logger_name":"akka.actor.ActorSystemImpl","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-24","level":"ERROR","level_value":40000,"stack_trace":"java.lang.RuntimeException: Message, hex encoded:\n1400000010001e000800140000000c0007001000100000000000000c900000004801000034000000e29094a18e0fd74100002600540030000000040008000c001000380040004800140018001c002000240028002c000000260000006e0f0000710400006a1f000071040000d40000009c000000780000006c0000005c00000044000000cc050000600c389bd35e3940000000c0a78f334000000000e4540f4000000080164a2f40000000001200000030303030303030303030303030303030303000000e0000003139322e3136382e35322e31323800000500000061656769730000000000000000000000180000006c696270636170302e383a616d643634ab312e372e342d32000000002e000000322e342e342d3230206275696c642061742053756e204a616e2031332031383a33353a343120555443203230313900002100000028446f636b657229205562756e74752031362e30342e35204c5453204c696e7578000000290000006d6f6e69746f72696e672d73797374656d2d6e6574776f726b2d6d6f6e69746f722d626f6864616e61000000\ncannot be repacked, dropped.\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:56)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$.$anonfun$packerFlow$1(ProtoPacker.scala:476)\n\tat akka.stream.impl.fusing.Map$$anon$9.onPush(Ops.scala:51)\n\tat akka.stream.impl.fusing.GraphInterpreter.processPush(GraphInterpreter.scala:519)\n\tat akka.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:411)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:588)\n\tat akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:472)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:563)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:745)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:760)\n\tat akka.actor.Actor.aroundReceive(Actor.scala:517)\n\tat akka.actor.Actor.aroundReceive$(Actor.scala:515)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:670)\n\tat akka.actor.ActorCell.receiveMessage(ActorCell.scala:588)\n\tat akka.actor.ActorCell.invoke(ActorCell.scala:557)\n\tat akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)\n\tat akka.dispatch.Mailbox.run(Mailbox.scala:225)\n\tat akka.dispatch.Mailbox.exec(Mailbox.scala:235)\n\tat akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)\n\tat akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)\n\tat akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)\n\tat akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)\nCaused by: java.lang.Error: java.nio.charset.MalformedInputException: Input length = 1\n\tat com.google.flatbuffers.Table.__string(Table.java:125)\n\tat com.sageaxcess.flatbuffer.SystemStatsData.pcapVersion(SystemStatsData.java:29)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$SystemStatsPacker.packSpecific(ProtoPacker.scala:393)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.flat2proto(ProtoPacker.scala:78)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:48)\n\t... 21 common frames omitted\nCaused by: java.nio.charset.MalformedInputException: Input length = 1\n\tat java.nio.charset.CoderResult.throwException(CoderResult.java:281)\n\tat com.google.flatbuffers.Table.__string(Table.java:122)\n\t... 25 common frames omitted\n","sourceThread":"aegis-aggregator-akka.actor.default-dispatcher-4","akkaSource":"akka.actor.ActorSystemImpl(aegis-aggregator)","sourceActorSystem":"aegis-aggregator","akkaTimestamp":"19:55:26.926UTC"}
55{"@timestamp":"2019-01-15T19:55:26.932+00:00","@version":1,"message":"proto-packer error","logger_name":"akka.actor.ActorSystemImpl","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-3","level":"ERROR","level_value":40000,"stack_trace":"java.lang.RuntimeException: Message, hex encoded:\n1400000010001e000800140000000c0007001000100000000000000c9000000048010000340000002f3115a98e0fd74100002600540030000000040008000c001000380040004800140018001c002000240028002c000000260000006e0f0000850500006a1f000085050000d40000009c000000780000006c0000005c00000044000000cc05000024b569a008ea3f40000000c0a78f3340000000000e550f40000000000c4a2f40000000001200000030303030303030303030303030303030303000000e0000003139322e3136382e35322e31323800000500000061656769730000000000000000000000180000006c696270636170302e383a616d643634ab312e372e342d32000000002e000000322e342e342d3230206275696c642061742053756e204a616e2031332031383a33353a343120555443203230313900002100000028446f636b657229205562756e74752031362e30342e35204c5453204c696e7578000000290000006d6f6e69746f72696e672d73797374656d2d6e6574776f726b2d6d6f6e69746f722d626f6864616e61000000\ncannot be repacked, dropped.\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:56)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$.$anonfun$packerFlow$1(ProtoPacker.scala:476)\n\tat akka.stream.impl.fusing.Map$$anon$9.onPush(Ops.scala:51)\n\tat akka.stream.impl.fusing.GraphInterpreter.processPush(GraphInterpreter.scala:519)\n\tat akka.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:411)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:588)\n\tat akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:472)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:563)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:745)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:760)\n\tat akka.actor.Actor.aroundReceive(Actor.scala:517)\n\tat akka.actor.Actor.aroundReceive$(Actor.scala:515)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:670)\n\tat akka.actor.ActorCell.receiveMessage(ActorCell.scala:588)\n\tat akka.actor.ActorCell.invoke(ActorCell.scala:557)\n\tat akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)\n\tat akka.dispatch.Mailbox.run(Mailbox.scala:225)\n\tat akka.dispatch.Mailbox.exec(Mailbox.scala:235)\n\tat akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)\n\tat akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)\n\tat akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)\n\tat akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)\nCaused by: java.lang.Error: java.nio.charset.MalformedInputException: Input length = 1\n\tat com.google.flatbuffers.Table.__string(Table.java:125)\n\tat com.sageaxcess.flatbuffer.SystemStatsData.pcapVersion(SystemStatsData.java:29)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$SystemStatsPacker.packSpecific(ProtoPacker.scala:393)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.flat2proto(ProtoPacker.scala:78)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:48)\n\t... 21 common frames omitted\nCaused by: java.nio.charset.MalformedInputException: Input length = 1\n\tat java.nio.charset.CoderResult.throwException(CoderResult.java:281)\n\tat com.google.flatbuffers.Table.__string(Table.java:122)\n\t... 25 common frames omitted\n","sourceThread":"aegis-aggregator-akka.actor.default-dispatcher-4","akkaSource":"akka.actor.ActorSystemImpl(aegis-aggregator)","sourceActorSystem":"aegis-aggregator","akkaTimestamp":"19:55:26.930UTC"}
56{"@timestamp":"2019-01-15T19:55:26.974+00:00","@version":1,"message":"[HTTP writer] Element: 1 messages written to /etc/sv/aegis-aggregator/tmp/aggregated-events-190115195400.http.parquet","logger_name":"akka.stream.Materializer","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-3","level":"INFO","level_value":20000,"sourceThread":"aegis-aggregator-akka.actor.default-dispatcher-2","akkaTimestamp":"19:55:26.974UTC","akkaSource":"akka.stream.Log(akka://aegis-aggregator/system/StreamSupervisor-0)","sourceActorSystem":"aegis-aggregator"}
57{"@timestamp":"2019-01-15T19:55:27.663+00:00","@version":1,"message":"Send parquet FileReady(/etc/sv/aegis-aggregator/ready/aggregated-events-190115195400.http.parquet,HTTP,190115195500): OK","logger_name":"com.sageaxcess.aegisaggregator.stream.Sender$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-3","level":"INFO","level_value":20000}
58{"@timestamp":"2019-01-15T19:55:27.663+00:00","@version":1,"message":"Deleting temp file: FileReady(/etc/sv/aegis-aggregator/ready/aggregated-events-190115195400.http.parquet,HTTP,190115195500)","logger_name":"com.sageaxcess.aegisaggregator.stream.Sender$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-3","level":"INFO","level_value":20000}
59{"@timestamp":"2019-01-15T19:55:29.113+00:00","@version":1,"message":"Unresolvable IP, \nIP hex: 6bb5bfbd\n ","logger_name":"com.sageaxcess.aegisaggregator.stream.HostnameResolver$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-24","level":"DEBUG","level_value":10000}
60{"@timestamp":"2019-01-15T19:55:29.115+00:00","@version":1,"message":"Unresolvable IP, \nIP hex: e00000fc\n ","logger_name":"com.sageaxcess.aegisaggregator.stream.HostnameResolver$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-16","level":"DEBUG","level_value":10000}
61{"@timestamp":"2019-01-15T19:55:45.814+00:00","@version":1,"message":"Unresolvable IP, \nIP hex: effffffa\n ","logger_name":"com.sageaxcess.aegisaggregator.stream.HostnameResolver$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-21","level":"DEBUG","level_value":10000}
62{"@timestamp":"2019-01-15T19:55:46.358+00:00","@version":1,"message":"proto-packer error","logger_name":"akka.actor.ActorSystemImpl","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-4","level":"ERROR","level_value":40000,"stack_trace":"java.lang.RuntimeException: Message, hex encoded:\n1400000010001e000800140000000c0007001000100000000000000c9000000048010000340000003c8594b08e0fd74100002600540030000000040008000c001000380040004800140018001c002000240028002c000000260000006e0f00008f0500006a1f00008f050000d40000009c000000780000006c0000005c00000044000000cc0500008e958f3854213a40000000c0a78f33400000000018550f4000000080094a2f40000000001200000030303030303030303030303030303030303000000e0000003139322e3136382e35322e31323800000500000061656769730000000000000000000000180000006c696270636170302e383a616d643634ad312e372e342d32000000002e000000322e342e342d3230206275696c642061742053756e204a616e2031332031383a33353a343120555443203230313900002100000028446f636b657229205562756e74752031362e30342e35204c5453204c696e7578000000290000006d6f6e69746f72696e672d73797374656d2d6e6574776f726b2d6d6f6e69746f722d626f6864616e61000000\ncannot be repacked, dropped.\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:56)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$.$anonfun$packerFlow$1(ProtoPacker.scala:476)\n\tat akka.stream.impl.fusing.Map$$anon$9.onPush(Ops.scala:51)\n\tat akka.stream.impl.fusing.GraphInterpreter.processPush(GraphInterpreter.scala:519)\n\tat akka.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:411)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:588)\n\tat akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:472)\n\tat akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:563)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:745)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:760)\n\tat akka.actor.Actor.aroundReceive(Actor.scala:517)\n\tat akka.actor.Actor.aroundReceive$(Actor.scala:515)\n\tat akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:670)\n\tat akka.actor.ActorCell.receiveMessage(ActorCell.scala:588)\n\tat akka.actor.ActorCell.invoke(ActorCell.scala:557)\n\tat akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)\n\tat akka.dispatch.Mailbox.run(Mailbox.scala:225)\n\tat akka.dispatch.Mailbox.exec(Mailbox.scala:235)\n\tat akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)\n\tat akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)\n\tat akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)\n\tat akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)\nCaused by: java.lang.Error: java.nio.charset.MalformedInputException: Input length = 1\n\tat com.google.flatbuffers.Table.__string(Table.java:125)\n\tat com.sageaxcess.flatbuffer.SystemStatsData.pcapVersion(SystemStatsData.java:29)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$SystemStatsPacker.packSpecific(ProtoPacker.scala:393)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.flat2proto(ProtoPacker.scala:78)\n\tat com.sageaxcess.aegisaggregator.stream.ProtoPacker$Packer.convertAndLog(ProtoPacker.scala:48)\n\t... 21 common frames omitted\nCaused by: java.nio.charset.MalformedInputException: Input length = 1\n\tat java.nio.charset.CoderResult.throwException(CoderResult.java:281)\n\tat com.google.flatbuffers.Table.__string(Table.java:122)\n\t... 25 common frames omitted\n","sourceThread":"aegis-aggregator-akka.actor.default-dispatcher-21","akkaSource":"akka.actor.ActorSystemImpl(aegis-aggregator)","sourceActorSystem":"aegis-aggregator","akkaTimestamp":"19:55:46.357UTC"}
63{"@timestamp":"2019-01-15T19:55:51.635+00:00","@version":1,"message":"0 files successfully uploaded","logger_name":"com.sageaxcess.aegisaggregator.stream.Sender$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-4","level":"INFO","level_value":20000}
64{"@timestamp":"2019-01-15T19:55:51.855+00:00","@version":1,"message":"total messages: 35 , rate: 0 msg/sec","logger_name":"ZMQ Source","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-4","level":"INFO","level_value":20000}
65{"@timestamp":"2019-01-15T19:55:51.855+00:00","@version":1,"message":"total messages: 35 , rate: 0 msg/sec","logger_name":"ZMQ Source","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-4","level":"INFO","level_value":20000}
66{"@timestamp":"2019-01-15T19:56:00.138+00:00","@version":1,"message":"Send aggregator heartbeat: OK","logger_name":"com.sageaxcess.aegisaggregator.monitoring.Heartbeats$","thread_name":"aegis-aggregator-akka.actor.default-dispatcher-21","level":"INFO","level_value":20000}