cygnus-ngsi_1 | 2017-12-20T16:16:54.586378023Z time=2017-12-20T16:16:54.586Z | lvl=INFO | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=getEvents | msg=com.telefonica.iot.cygnus.handlers.NGSIRestHandler[294] : [NGSIRestHandler] Starting internal transaction (5ec1caf8-1972-4021-ac57-fb78bc48cca9) cygnus-ngsi_1 | 2017-12-20T16:16:54.587039854Z time=2017-12-20T16:16:54.586Z | lvl=INFO | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=getEvents | msg=com.telefonica.iot.cygnus.handlers.NGSIRestHandler[312] : [NGSIRestHandler] Received data ({ "subscriptionId" : "51c0ac9ed714fb3b37d7d5a8", "originator" : "localhost", "contextResponses" : [ { "contextElement" : { "attributes" : [ { "name" : "temperature", "type" : "centigrade", "value" : "26.5" }, { "name" : "the_geom", "type" : "geometry", "value" : ", ", "metadatas": [ { "name": "location", "type": "string", "value": "WGS84" } ] } ], "type" : "Car", "isPattern" : "false", "id" : "Car1" }, "statusCode" : { "code" : "200", "reasonPhrase" : "OK" } } ]}) cygnus-ngsi_1 | 2017-12-20T16:16:54.649653920Z time=2017-12-20T16:16:54.649Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=getEvents | msg=com.telefonica.iot.cygnus.handlers.NGSIRestHandler[320] : [NGSIRestHandler] Parsed NotifyContextRequest: {"subscriptionId":"51c0ac9ed714fb3b37d7d5a8","originator":"localhost","contextResponses":[{"contextElement":{"id":"Car1","type":"Car","isPattern":"false","attributes":[{"name":"temperature","type":"centigrade","value":"26.5","metadatas":[]},{"name":"the_geom","type":"geometry","value":", ","metadatas":[{"name":"location","type":"string","value":"WGS84"}]}]},"statusCode":{"code":"200","reasonPhrase":"OK"}}]} cygnus-ngsi_1 | 2017-12-20T16:16:54.649687935Z time=2017-12-20T16:16:54.649Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=getEvents | msg=com.telefonica.iot.cygnus.handlers.NGSIRestHandler[345] : [NGSIRestHandler] NGSI event created for ContextElementResponse: {"contextElement":{"id":"Car1","type":"Car","isPattern":"false","attributes":[{"name":"temperature","type":"centigrade","value":"26.5","metadatas":[]},{"name":"the_geom","type":"geometry","value":", ","metadatas":[{"name":"location","type":"string","value":"WGS84"}]}]},"statusCode":{"code":"200","reasonPhrase":"OK"}} cygnus-ngsi_1 | 2017-12-20T16:16:54.649781717Z time=2017-12-20T16:16:54.649Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=getEvents | msg=com.telefonica.iot.cygnus.handlers.NGSIRestHandler[350] : [NGSIRestHandler] Header added to NGSI event (fiware-service: default) cygnus-ngsi_1 | 2017-12-20T16:16:54.649949133Z time=2017-12-20T16:16:54.649Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=getEvents | msg=com.telefonica.iot.cygnus.handlers.NGSIRestHandler[353] : [NGSIRestHandler] Header added to NGSI event (fiware-servicepath: /) cygnus-ngsi_1 | 2017-12-20T16:16:54.650115082Z time=2017-12-20T16:16:54.649Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=getEvents | msg=com.telefonica.iot.cygnus.handlers.NGSIRestHandler[356] : [NGSIRestHandler] Header added to NGSI event (fiware-correlator: 5ec1caf8-1972-4021-ac57-fb78bc48cca9) cygnus-ngsi_1 | 2017-12-20T16:16:54.650281925Z time=2017-12-20T16:16:54.650Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=getEvents | msg=com.telefonica.iot.cygnus.handlers.NGSIRestHandler[359] : [NGSIRestHandler] Header added to NGSI event (transaction-id: 5ec1caf8-1972-4021-ac57-fb78bc48cca9) cygnus-ngsi_1 | 2017-12-20T16:16:54.651105909Z time=2017-12-20T16:16:54.650Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=getEvents | msg=com.telefonica.iot.cygnus.handlers.NGSIRestHandler[385] : [NGSIRestHandler] NGSI events put in the channel, ids=839243882 cygnus-ngsi_1 | 2017-12-20T16:16:54.651440931Z time=2017-12-20T16:16:54.651Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=intercept | msg=com.telefonica.iot.cygnus.interceptors.NGSIGroupingInterceptor[84] : [gi] Event intercepted, id=839243882 cygnus-ngsi_1 | 2017-12-20T16:16:54.651608565Z time=2017-12-20T16:16:54.651Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=intercept | msg=com.telefonica.iot.cygnus.interceptors.NGSIGroupingInterceptor[117] : [gi] Adding flume event header (notified-entity: Car1_Car) cygnus-ngsi_1 | 2017-12-20T16:16:54.651775814Z time=2017-12-20T16:16:54.651Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=intercept | msg=com.telefonica.iot.cygnus.interceptors.NGSIGroupingInterceptor[120] : [gi] Adding flume event header (grouped-entity: Car1_Car) cygnus-ngsi_1 | 2017-12-20T16:16:54.651943558Z time=2017-12-20T16:16:54.651Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=intercept | msg=com.telefonica.iot.cygnus.interceptors.NGSIGroupingInterceptor[123] : [gi] Adding flume event header (grouped-servicepath: /) cygnus-ngsi_1 | 2017-12-20T16:16:54.652111840Z time=2017-12-20T16:16:54.651Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=intercept | msg=com.telefonica.iot.cygnus.interceptors.NGSIGroupingInterceptor[127] : [gi] Event put in the channel, id=839243882 cygnus-ngsi_1 | 2017-12-20T16:16:55.246177815Z time=2017-12-20T16:16:55.245Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=processNewBatches | msg=com.telefonica.iot.cygnus.sinks.NGSISink[554] : Batch completed cygnus-ngsi_1 | 2017-12-20T16:16:55.246220256Z time=2017-12-20T16:16:55.246Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=persistBatch | msg=com.telefonica.iot.cygnus.sinks.NGSICartoDBSink[381] : [cartodb-sink] Processing sub-batch regarding the default_/_Car1_Car destination cygnus-ngsi_1 | 2017-12-20T16:16:55.257123107Z time=2017-12-20T16:16:55.256Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=aggregate | msg=com.telefonica.iot.cygnus.sinks.NGSICartoDBSink$CartoDBAggregator[570] : [cartodb-sink] Processing context element (id=Car1, type=Car) cygnus-ngsi_1 | 2017-12-20T16:16:55.257152319Z time=2017-12-20T16:16:55.256Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=aggregate | msg=com.telefonica.iot.cygnus.sinks.NGSICartoDBSink$CartoDBAggregator[592] : [cartodb-sink] Processing context attribute (name=temperature, type=centigrade) cygnus-ngsi_1 | 2017-12-20T16:16:55.257436049Z time=2017-12-20T16:16:55.257Z | lvl=DEBUG | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=aggregate | msg=com.telefonica.iot.cygnus.sinks.NGSICartoDBSink$CartoDBAggregator[592] : [cartodb-sink] Processing context attribute (name=the_geom, type=geometry) cygnus-ngsi_1 | 2017-12-20T16:16:55.257732286Z time=2017-12-20T16:16:55.257Z | lvl=INFO | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=persistRawAggregation | msg=com.telefonica.iot.cygnus.sinks.NGSICartoDBSink[616] : [cartodb-sink] Persisting data at NGSICartoDBSink. Schema (default), Table (x002fxffffx0043ar1xffffx0043ar), Data (('2017-12-20T16:16:54.651Z','/','Car1','Car',ST_SetSRID(ST_MakePoint(,), 4326),'26.5','[]')) cygnus-ngsi_1 | 2017-12-20T16:16:55.259618557Z time=2017-12-20T16:16:55.258Z | lvl=ERROR | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160] : Unable to deliver event. Exception follows. cygnus-ngsi_1 | 2017-12-20T16:16:55.259632910Z java.lang.NullPointerException cygnus-ngsi_1 | 2017-12-20T16:16:55.259636430Z at com.telefonica.iot.cygnus.sinks.NGSICartoDBSink.persistRawAggregation(NGSICartoDBSink.java:625) cygnus-ngsi_1 | 2017-12-20T16:16:55.259639395Z at com.telefonica.iot.cygnus.sinks.NGSICartoDBSink.persistBatch(NGSICartoDBSink.java:417) cygnus-ngsi_1 | 2017-12-20T16:16:55.259643325Z at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:558) cygnus-ngsi_1 | 2017-12-20T16:16:55.259645857Z at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:370) cygnus-ngsi_1 | 2017-12-20T16:16:55.259648425Z at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68) cygnus-ngsi_1 | 2017-12-20T16:16:55.259651037Z at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147) cygnus-ngsi_1 | 2017-12-20T16:16:55.259653547Z at java.lang.Thread.run(Thread.java:748) cygnus-ngsi_1 | 2017-12-20T16:17:00.260728752Z time=2017-12-20T16:17:00.260Z | lvl=ERROR | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160] : Unable to deliver event. Exception follows. cygnus-ngsi_1 | 2017-12-20T16:17:00.260757599Z java.lang.IllegalStateException: begin() called when transaction is OPEN! cygnus-ngsi_1 | 2017-12-20T16:17:00.260761309Z at com.google.common.base.Preconditions.checkState(Preconditions.java:145) cygnus-ngsi_1 | 2017-12-20T16:17:00.260764359Z at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131) cygnus-ngsi_1 | 2017-12-20T16:17:00.260767151Z at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:482) cygnus-ngsi_1 | 2017-12-20T16:17:00.260769842Z at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:370) cygnus-ngsi_1 | 2017-12-20T16:17:00.260784698Z at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68) cygnus-ngsi_1 | 2017-12-20T16:17:00.260787712Z at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147) cygnus-ngsi_1 | 2017-12-20T16:17:00.260790256Z at java.lang.Thread.run(Thread.java:748) cygnus-ngsi_1 | 2017-12-20T16:17:03.102666361Z time=2017-12-20T16:17:03.102Z | lvl=DEBUG | corr=N/A | trans=N/A | srv=N/A | subsrv=N/A | comp=cygnus-ngsi | op=run | msg=org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable[126] : Checking file:/opt/apache-flume/conf/agent.conf for changes cygnus-ngsi_1 | 2017-12-20T16:17:03.116374962Z time=2017-12-20T16:17:03.115Z | lvl=WARN | corr=N/A | trans=N/A | srv=N/A | subsrv=N/A | comp=cygnus-ngsi | op= | msg=com.telefonica.iot.cygnus.interceptors.CygnusGroupingRules[49] : No grouping rules have been read. Details: /usr/cygnus/conf/grouping_rules.conf (No such file or directory) cygnus-ngsi_1 | 2017-12-20T16:17:05.261339261Z time=2017-12-20T16:17:05.260Z | lvl=ERROR | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160] : Unable to deliver event. Exception follows. cygnus-ngsi_1 | 2017-12-20T16:17:05.261368680Z java.lang.IllegalStateException: begin() called when transaction is OPEN! cygnus-ngsi_1 | 2017-12-20T16:17:05.261372739Z at com.google.common.base.Preconditions.checkState(Preconditions.java:145) cygnus-ngsi_1 | 2017-12-20T16:17:05.261376078Z at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131) cygnus-ngsi_1 | 2017-12-20T16:17:05.261379104Z at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:482) cygnus-ngsi_1 | 2017-12-20T16:17:05.261382038Z at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:370) cygnus-ngsi_1 | 2017-12-20T16:17:05.261384947Z at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68) cygnus-ngsi_1 | 2017-12-20T16:17:05.261387928Z at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147) cygnus-ngsi_1 | 2017-12-20T16:17:05.261390817Z at java.lang.Thread.run(Thread.java:748) cygnus-ngsi_1 | 2017-12-20T16:17:10.262020846Z time=2017-12-20T16:17:10.261Z | lvl=ERROR | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160] : Unable to deliver event. Exception follows. cygnus-ngsi_1 | 2017-12-20T16:17:10.262065339Z java.lang.IllegalStateException: begin() called when transaction is OPEN! cygnus-ngsi_1 | 2017-12-20T16:17:10.262070038Z at com.google.common.base.Preconditions.checkState(Preconditions.java:145) cygnus-ngsi_1 | 2017-12-20T16:17:10.262073562Z at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131) cygnus-ngsi_1 | 2017-12-20T16:17:10.262076685Z at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:482) cygnus-ngsi_1 | 2017-12-20T16:17:10.262079595Z at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:370) cygnus-ngsi_1 | 2017-12-20T16:17:10.262082479Z at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68) cygnus-ngsi_1 | 2017-12-20T16:17:10.262085521Z at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147) cygnus-ngsi_1 | 2017-12-20T16:17:10.262100755Z at java.lang.Thread.run(Thread.java:748) cygnus-ngsi_1 | 2017-12-20T16:17:15.262622173Z time=2017-12-20T16:17:15.261Z | lvl=ERROR | corr=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | trans=5ec1caf8-1972-4021-ac57-fb78bc48cca9 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160] : Unable to deliver event. Exception follows.