Uploaded image for project: 'Help-Desk'
  1. Help-Desk
  2. HELP-13326

[fiware-stackoverflow] My Cygnus agent doesn't create a MySQL database

        Details

          Description

          Created question in FIWARE Q/A platform on 17-11-2017 at 14:11
          Please, ANSWER this question AT https://stackoverflow.com/questions/47352123/my-cygnus-agent-doesnt-create-a-mysql-database

          Question:
          My Cygnus agent doesn't create a MySQL database

          Description:
          Good afternoon!

          Following the documentation of http://fiware-cygnus.readthedocs.io I created my two conf as follows:

          cygnus_instance_1.conf (EDIT: UPDATED AT 2017/11/23)

          CYGNUS_USER=cygnus
          CONFIG_FOLDER=/usr/cygnus/conf
          CONFIG_FILE=/usr/cygnus/conf/agent_1.conf
          AGENT_NAME=cygnus-ngsi
          LOGFILE_NAME=cygnus.log
          ADMIN_PORT=8081
          POLLING_INTERVAL=30

          agent_1.conf (EDIT: UPDATED AT 2017/12/1)

          cygnus-ngsi.sources = http-source
          cygnus-ngsi.sinks = mysql-sink
          cygnus-ngsi.channels = mysql-channel

          cygnus-ngsi.sources.http-source.channels = mysql-channel
          cygnus-ngsi.sources.http-source.type = org.apache.flume.source.http.HTTPSource
          cygnus-ngsi.sources.http-source.port = 5050
          cygnus-ngsi.sources.http-source.handler = com.telefonica.iot.cygnus.handlers.NGSIRestHandler
          cygnus-ngsi.sources.http-source.handler.notification_target = /notify
          cygnus-ngsi.sources.http-source.handler.default_service =
          cygnus-ngsi.sources.http-source.handler.default_service_path = /
          cygnus-ngsi.sources.http-source.handler.events_ttl = 2
          cygnus-ngsi.sources.http-source.interceptors = ts
          cygnus-ngsi.sources.http-source.interceptors.ts.type = timestamp

          cygnus-ngsi.channels.mysql-channel.type = memory
          cygnus-ngsi.channels.mysql-channel.capacity = 1000
          cygnus-ngsi.channels.mysql-channel.transactionCapacity = 100

          cygnus-ngsi.sinks.mysql-sink.mysql_port = 3306
          cygnus-ngsi.sinks.mysql-sink.mysql_host = localhost
          cygnus-ngsi.sinks.mysql-sink.enable_grouping = true
          cygnus-ngsi.sinks.mysql-sink.mysql_password = *********
          cygnus-ngsi.sinks.mysql-sink.type = com.telefonica.iot.cygnus.sinks.NGSIMySQLSink
          cygnus-ngsi.sinks.mysql-sink.batch_timeout = 10
          cygnus-ngsi.sinks.mysql-sink.mysql_username = username
          cygnus-ngsi.sinks.mysql-sink.batch_size = 1
          cygnus-ngsi.sinks.mysql-sink.channel = mysql-channel
          cygnus-ngsi.sinks.mysql-sink.new_parameter = new_value
          cygnus-ngsi.sinks.mysql-sink.data_model = dm-by-attribute
          cygnus-ngsi.sinks.mysql-sink.attr_persistence = row

          I previously created my subscription so that when the activity was changed, the previous entity was saved in MySQL.

          $ch = curl_init();

          curl_setopt($ch, CURLOPT_URL, "http://$IP_PUBLIC:1026/v2/subscriptions");
          curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
          curl_setopt($ch, CURLOPT_HEADER, FALSE);

          curl_setopt($ch, CURLOPT_POST, TRUE);

          curl_setopt($ch, CURLOPT_POSTFIELDS, "{
          \"description\": \"One subscription to rule them all\",
          \"subject\": {
          \"entities\": [

          { \"idPattern\": \".*\", \"type\": \"ExerciseAction\" }

          ],
          \"condition\":

          { \"attrs\": [ \"startTime\" ] }

          },
          \"notification\": {
          \"http\":

          { \"url\": \"http://$IP_PUBLIC:5050/notify\" }

          ,
          \"attrs\": [
          \"startTime\"
          ]
          },
          \"expires\": \"2020-04-05T14:00:00.00Z\"
          }");

          curl_setopt($ch, CURLOPT_HTTPHEADER, array(
          "Content-Type: application/json"
          ));

          $response = curl_exec($ch);
          curl_close($ch);

          var_dump($response);

          cygnus.log after update entity

          time=2017-12-01T12:52:50.539Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:52:53.031Z | lvl=INFO | corr=8b61fc74-d696-11e7-a933-fa163ec68c31 | trans=ccb60fea-10f8-46eb-82fa-8864f9352e41 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=getEvents |

          msg=com.telefonica.iot.cygnus.handlers.NGSIRestHandler[286] : [NGSIRestHandler] Starting internal transaction (ccb60fea-10f8-46eb-82fa-8864f9352e41)
          time=2017-12-01T12:52:53.042Z | lvl=INFO | corr=8b61fc74-d696-11e7-a933-fa163ec68c31 | trans=ccb60fea-10f8-46eb-82fa-8864f9352e41 | srv=default | subsrv=/ | comp=cygnus-ngsi | op=getEvents |

          msg=com.telefonica.iot.cygnus.handlers.NGSIRestHandler[304] : [NGSIRestHandler] Received data ({ "subscriptionId" : "5a2150a4d3258a6d7c656d26", "originator" : "localhost", "contextResponses" : [ { "contextElement" : {

          "type" : "ExerciseAction", "isPattern" : "false", "id" : "75", "attributes" : [

          { "name" : "startTime", "type" : "Text", "value" : "30/11/2017 14:38:40" }

          ]

          }, "statusCode" :

          { "code" : "200", "reasonPhrase" : "OK" }

          } ]})
          time=2017-12-01T12:52:55.546Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:53:00.548Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:53:05.550Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:53:10.551Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:53:15.554Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:53:20.558Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:53:25.559Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:53:30.561Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:53:35.568Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:53:40.569Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:53:45.570Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:53:50.571Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:53:55.574Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:54:00.575Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:54:05.576Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:54:10.580Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)
          time=2017-12-01T12:54:15.588Z | lvl=ERROR | corr=cdeca432-d695-11e7-9c51-fa163ec68c31 | trans=fe9234ec-055b-483d-876d-e15d442a0efe | srv=default | subsrv=/ | comp=cygnus-ngsi | op=run | msg=org.apache.flume.SinkRunner$PollingRunner[160]

          : Unable to deliver event. Exception follows.
          java.lang.IllegalStateException: begin() called when transaction is OPEN!
          at com.google.common.base.Preconditions.checkState(Preconditions.java:145)
          at org.apache.flume.channel.BasicTransactionSemantics.begin(BasicTransactionSemantics.java:131)
          at com.telefonica.iot.cygnus.sinks.NGSISink.processNewBatches(NGSISink.java:476)
          at com.telefonica.iot.cygnus.sinks.NGSISink.process(NGSISink.java:368)
          at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
          at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
          at java.lang.Thread.run(Thread.java:748)

          Can someone help me and tell me why the connection between my Cygnus and MySQL does not work?
          Thank you so much!!!

            Activity

            Descending order - Click to sort in ascending order
            Hide
            Permalink
            backlogmanager Backlog Manager added a comment -

            2018-01-12 20:02|UPDATED status: transition Finish| # answers= 1, accepted answer= True

            Show
            backlogmanager Backlog Manager added a comment - 2018-01-12 20:02|UPDATED status: transition Finish| # answers= 1, accepted answer= True
            Hide
            Permalink
            backlogmanager Backlog Manager added a comment -

            2018-01-12 19:53|UPDATED status: transition Answer| # answers= 1, accepted answer= True

            Show
            backlogmanager Backlog Manager added a comment - 2018-01-12 19:53|UPDATED status: transition Answer| # answers= 1, accepted answer= True
            Hide
            Permalink
            backlogmanager Backlog Manager added a comment -

            2018-01-12 19:50|CREATED monitor | # answers= 1, accepted answer= True

            Show
            backlogmanager Backlog Manager added a comment - 2018-01-12 19:50|CREATED monitor | # answers= 1, accepted answer= True

              People

              • Assignee:
                frb Francisco Romero
                Reporter:
                backlogmanager Backlog Manager
              • Votes:
                0 Vote for this issue
                Watchers:
                1 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: