[centos@orion bin]$ ./cygnus-flume-ng agent -f ../conf/mysql_agent.conf -n cygnus-ngsi -Dflume.root.logger=DEBUG,console
Warning: No configuration directory set! Use --conf <dir> to override.
+ exec /usr/lib/jvm/java-1.8.0-openjdk.x86_64//bin/java -Xmx20m -Dflume.root.logger=DEBUG,console -cp '/usr/cygnus/lib/*:/usr/cygnus/plugins.d/cygnus/lib/*:/usr/cygnus/plugins.d/cygnus/libext/*' -Djava.library.path= com.telefonica.iot.cygnus.nodes.CygnusApplication -f ../conf/mysql_agent.conf -n cygnus-ngsi
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/usr/cygnus/lib/slf4j-log4j12-1.6.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/usr/cygnus/plugins.d/cygnus/lib/cygnus-ngsi-1.7.1-jar-with-dependencies.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/usr/cygnus/plugins.d/cygnus/libext/cygnus-common-1.7.1-jar-with-dependencies.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
18/05/29 15:09:53 INFO nodes.CygnusApplication: Starting Cygnus, version 1.7.1.UNKNOWN
18/05/29 15:09:53 INFO nodes.CygnusApplication: Waiting for valid Flume components references...
18/05/29 15:09:53 INFO node.PollingPropertiesFileConfigurationProvider: Configuration provider starting
18/05/29 15:09:53 INFO node.PollingPropertiesFileConfigurationProvider: Reloading configuration file:../conf/mysql_agent.conf
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Added sinks: mysql-sink Agent: cygnus-ngsi
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Processing:mysql-sink
18/05/29 15:09:53 INFO conf.FlumeConfiguration: Post-validation flume configuration contains configuration for agents: [cygnus-ngsi]
18/05/29 15:09:53 INFO node.AbstractConfigurationProvider: Creating channels
18/05/29 15:09:53 INFO channel.DefaultChannelFactory: Creating instance of channel mysql-channel type memory
18/05/29 15:09:53 INFO node.AbstractConfigurationProvider: Created channel mysql-channel
18/05/29 15:09:53 INFO source.DefaultSourceFactory: Creating instance of source http-source, type org.apache.flume.source.http.HTTPSource
18/05/29 15:09:53 INFO handlers.NGSIRestHandler: [NGSIRestHandler] Startup completed
18/05/29 15:09:53 INFO sink.DefaultSinkFactory: Creating instance of sink: mysql-sink, type: com.telefonica.iot.cygnus.sinks.NGSIMySQLSink
18/05/29 15:09:53 INFO node.AbstractConfigurationProvider: Channel mysql-channel connected to [http-source, mysql-sink]
18/05/29 15:09:53 INFO node.Application: Starting new configuration:{ sourceRunners:{http-source=EventDrivenSourceRunner: { source:org.apache.flume.source.http.HTTPSource{name:http-source,state:IDLE} }} sinkRunners:{mysql-sink=SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@4d6b9394 counterGroup:{ name:null counters:{} } }} channels:{mysql-channel=org.apache.flume.channel.MemoryChannel{name: mysql-channel}} }
18/05/29 15:09:53 INFO node.Application: Starting Channel mysql-channel
18/05/29 15:09:53 INFO instrumentation.MonitoredCounterGroup: Monitoried counter group for type: CHANNEL, name: mysql-channel, registered successfully.
18/05/29 15:09:53 INFO instrumentation.MonitoredCounterGroup: Component type: CHANNEL, name: mysql-channel started
18/05/29 15:09:53 INFO node.Application: Starting Sink mysql-sink
18/05/29 15:09:53 INFO node.Application: Starting Source http-source
18/05/29 15:09:53 WARN interceptors.CygnusGroupingRules: No grouping rules have been read. Details: /usr/cygnus/conf/grouping_rules.conf (No such file or directory)
18/05/29 15:09:53 INFO sinks.NGSISink: [mysql-sink] Startup completed
18/05/29 15:09:53 WARN interceptors.CygnusGroupingRules: No grouping rules have been read. Details: /usr/cygnus/conf/grouping_rules.conf (No such file or directory)
18/05/29 15:09:53 INFO mortbay.log: Logging to org.slf4j.impl.Log4jLoggerAdapter(org.mortbay.log) via org.mortbay.log.Slf4jLog
18/05/29 15:09:53 INFO mortbay.log: jetty-6.1.26
18/05/29 15:09:53 INFO mortbay.log: Started SocketConnector@0.0.0.0:5050
18/05/29 15:09:53 INFO instrumentation.MonitoredCounterGroup: Monitoried counter group for type: SOURCE, name: http-source, registered successfully.
18/05/29 15:09:53 INFO instrumentation.MonitoredCounterGroup: Component type: SOURCE, name: http-source started
18/05/29 15:09:54 INFO nodes.CygnusApplication: Starting a Jetty server listening on 0.0.0.0:8081 (Management Interface)
18/05/29 15:09:54 INFO mortbay.log: jetty-6.1.26
18/05/29 15:09:54 INFO mortbay.log: Started SelectChannelConnector@0.0.0.0:8081
18/05/29 15:10:23 WARN interceptors.CygnusGroupingRules: No grouping rules have been read. Details: /usr/cygnus/conf/grouping_rules.conf (No such file or directory)
18/05/29 15:10:29 INFO handlers.NGSIRestHandler: [NGSIRestHandler] Starting internal transaction (71ba5336-bf98-42ea-99b7-04976f940d7b)
18/05/29 15:10:29 INFO handlers.NGSIRestHandler: [NGSIRestHandler] Received data ({  "subscriptionId" : "5b0d6d65cb1aeaf960c0cfeb",  "originator" : "localhost",  "contextResponses" : [    {      "contextElement" : {        "type" : "Alert",        "isPattern" : "false",        "id" : "Alert1",        "attributes" : [          {            "name" : "humidity",            "type" : "double",            "value" : "60.0"          },          {            "name" : "temperature",            "type" : "double",            "value" : "18.0"          }        ]      },      "statusCode" : {        "code" : "200",        "reasonPhrase" : "OK"      }    }  ]})
18/05/29 15:10:53 WARN interceptors.CygnusGroupingRules: No grouping rules have been read. Details: /usr/cygnus/conf/grouping_rules.conf (No such file or directory)
18/05/29 15:10:55 INFO sinks.NGSIMySQLSink: [mysql-sink] Persisting data at NGSIMySQLSink. Database (hannover), Table (Messe_Alert1_Alert), Fields ((recvTimeTs,recvTime,fiwareServicePath,entityId,entityType,attrName,attrType,attrValue,attrMd)), Values (('1527606629525','2018-05-29T15:10:29.525','/Messe','Alert1','Alert','humidity','double','60.0','[]'),('1527606629525','2018-05-29T15:10:29.525','/Messe','Alert1','Alert','temperature','double','18.0','[]'))
18/05/29 15:10:55 ERROR sinks.NGSISink: Persistence error. Message: SQLException, Could not create connection to database server., Stack trace: [com.telefonica.iot.cygnus.backends.mysql.MySQLBackendImpl$MySQLDriver.getConnection(MySQLBackendImpl.java:416), com.telefonica.iot.cygnus.backends.mysql.MySQLBackendImpl.createDatabase(MySQLBackendImpl.java:86), com.telefonica.iot.cygnus.sinks.NGSIMySQLSink.persistAggregation(NGSIMySQLSink.java:546), com.telefonica.iot.cygnus.sinks.NGSIMySQLSink.persistBatch(NGSIMySQLSink.java:200), com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:523), com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368), org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68), org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147), java.lang.Thread.run(Thread.java:748)]
18/05/29 15:10:55 INFO sinks.NGSISink: Rollbacking (6c828e74-6352-11e8-aa99-fa163eb3484f), 1 retries will be done
18/05/29 15:11:00 INFO sinks.NGSIMySQLSink: [mysql-sink] Persisting data at NGSIMySQLSink. Database (hannover), Table (Messe_Alert1_Alert), Fields ((recvTimeTs,recvTime,fiwareServicePath,entityId,entityType,attrName,attrType,attrValue,attrMd)), Values (('1527606629525','2018-05-29T15:10:29.525','/Messe','Alert1','Alert','humidity','double','60.0','[]'),('1527606629525','2018-05-29T15:10:29.525','/Messe','Alert1','Alert','temperature','double','18.0','[]'))
18/05/29 15:11:00 ERROR sinks.NGSISink: Persistence error. Message: SQLException, Could not create connection to database server., Stack trace: [com.telefonica.iot.cygnus.backends.mysql.MySQLBackendImpl$MySQLDriver.getConnection(MySQLBackendImpl.java:416), com.telefonica.iot.cygnus.backends.mysql.MySQLBackendImpl.createDatabase(MySQLBackendImpl.java:86), com.telefonica.iot.cygnus.sinks.NGSIMySQLSink.persistAggregation(NGSIMySQLSink.java:546), com.telefonica.iot.cygnus.sinks.NGSIMySQLSink.persistBatch(NGSIMySQLSink.java:200), com.telefonica.iot.cygnus.sinks.NGSISink.processRollbackedBatches(NGSISink.java:387), com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:370), org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68), org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147), java.lang.Thread.run(Thread.java:748)]
18/05/29 15:11:00 INFO sinks.NGSISink: Finishing internal transaction (6c828e74-6352-11e8-aa99-fa163eb3484f), this was retry #1