API tools faq
paste
Guest User

Untitled

a guest
May 3rd, 2018
167
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 9.75 KB | None | 0 0
raw download clone embed print report
  1. cygnus-ngsi.sources = http-source
  2. cygnus-ngsi.sinks = mysql-sink
  3. cygnus-ngsi.channels = mysql-channel
  4.  
  5. cygnus-ngsi.sources.http-source.channels = mysql-channel
  6. cygnus-ngsi.sources.http-source.type = org.apache.flume.source.http.HTTPSource
  7. cygnus-ngsi.sources.http-source.port = 5050
  8. cygnus-ngsi.sources.http-source.handler = com.telefonica.iot.cygnus.handlers.NGSIRestHandler
  9. cygnus-ngsi.sources.http-source.handler.notification_target = /notify
  10. cygnus-ngsi.sources.http-source.handler.default_service = def_serv
  11. cygnus-ngsi.sources.http-source.handler.default_service_path = def_servpath
  12. cygnus-ngsi.sources.http-source.handler.events_ttl = 2
  13. cygnus-ngsi.sources.http-source.interceptors = ts gi
  14. cygnus-ngsi.sources.http-source.interceptors.ts.type = timestamp
  15. cygnus-ngsi.sources.http-source.interceptors.gi.type = com.telefonica.iot.cygnus.interceptors.NGSIGroupingInterceptor$Builder
  16. cygnus-ngsi.sources.http-source.interceptors.gi.grouping_rules_conf_file = /Applications/apache-flume-1.4.0-bin/conf/grouping_rules.conf
  17.  
  18. # =============================================
  19. # mysql-channel configuration
  20. # channel type (must not be changed)
  21. cygnus-ngsi.channels.mysql-channel.type = memory
  22. # capacity of the channel
  23. cygnus-ngsi.channels.mysql-channel.capacity = 1000
  24. # amount of bytes that can be sent per transaction
  25. cygnus-ngsi.channels.mysql-channel.transactionCapacity = 100
  26.  
  27.  
  28.  
  29. # channel name from where to read notification events
  30. cygnus-ngsi.sinks.mysql-sink.channel = mysql-channel
  31. # sink class, must not be changed
  32. cygnus-ngsi.sinks.mysql-sink.type = com.telefonica.iot.cygnus.sinks.NGSIMySQLSink
  33. #com.telefonica.iot.cygnus.sinks.OrionMySQLSink
  34. # the FQDN/IP address where the MySQL server runs
  35. cygnus-ngsi.sinks.mysql-sink.mysql_host = localhost
  36. # the port where the MySQL server listes for incomming connections
  37. cygnus-ngsi.sinks.mysql-sink.mysql_port = 3306
  38. # a valid user in the MySQL server
  39. cygnus-ngsi.sinks.mysql-sink.mysql_username = root
  40. # password for the user above
  41. cygnus-ngsi.sinks.mysql-sink.mysql_password = <myPassword>
  42. # how the attributes are stored, either per row either per column (row, column)
  43. cygnus-ngsi.sinks.mysql-sink.attr_persistence = row
  44.  
  45. n$AgentConfiguration[1016] : Processing:mysql-sink
  46. time=2018-04-30T14:24:00.807Z | lvl=INFO | corr=N/A | trans=N/A | srv=N/A | subsrv=N/A | comp=cygnus-ngsi | op=validateConfiguration | msg=org.apache.flume.conf.FlumeConfiguration[140] : Post-validation flume configuration contains configuration for agents: [cygnus-ngsi]
  47. time=2018-04-30T14:24:00.808Z | lvl=INFO | corr=N/A | trans=N/A | srv=N/A | subsrv=N/A | comp=cygnus-ngsi | op=loadChannels | msg=org.apache.flume.node.AbstractConfigurationProvider[150] : Creating channels
  48. time=2018-04-30T14:24:00.816Z | lvl=INFO | corr=N/A | trans=N/A | srv=N/A | subsrv=N/A | comp=cygnus-ngsi | op=create | msg=org.apache.flume.channel.DefaultChannelFactory[40] : Creating instance of channel mysql-channel type memory
  49. time=2018-04-30T14:24:00.825Z | lvl=INFO | corr=N/A | trans=N/A | srv=N/A | subsrv=N/A | comp=cygnus-ngsi | op=loadChannels | msg=org.apache.flume.node.AbstractConfigurationProvider[205] : Created channel mysql-channel
  50. time=2018-04-30T14:24:00.832Z | lvl=INFO | corr=N/A | trans=N/A | srv=N/A | subsrv=N/A | comp=cygnus-ngsi | op=create | msg=org.apache.flume.source.DefaultSourceFactory[39] : Creating instance of source http-source, type org.apache.flume.source.http.HTTPSource
  51. time=2018-04-30T14:24:00.836Z | lvl=ERROR | corr=N/A | trans=N/A | srv=N/A | subsrv=N/A | comp=cygnus-ngsi | op=configure | msg=org.apache.flume.source.http.HTTPSource[113] : Error while configuring HTTPSource. Exception follows.
  52. java.lang.ClassNotFoundException: com.telefonica.iot.cygnus.handlers.NGSIRestHandler
  53. at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
  54. at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
  55. at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338)
  56. at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
  57. at java.lang.Class.forName0(Native Method)
  58. at java.lang.Class.forName(Class.java:264)
  59. at org.apache.flume.source.http.HTTPSource.configure(HTTPSource.java:102)
  60. at org.apache.flume.conf.Configurables.configure(Configurables.java:41)
  61. at org.apache.flume.node.AbstractConfigurationProvider.loadSources(AbstractConfigurationProvider.java:331)
  62. at org.apache.flume.node.AbstractConfigurationProvider.getConfiguration(AbstractConfigurationProvider.java:102)
  63. at org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run(PollingPropertiesFileConfigurationProvider.java:140)
  64. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  65. at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
  66. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
  67. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
  68. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  69. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  70. at java.lang.Thread.run(Thread.java:748)
  71. time=2018-04-30T14:24:00.840Z | lvl=ERROR | corr=N/A | trans=N/A | srv=N/A | subsrv=N/A | comp=cygnus-ngsi | op=loadSources | msg=org.apache.flume.node.AbstractConfigurationProvider[366] : Source http-source has been removed due to an error during configuration
  72. java.lang.RuntimeException: java.lang.ClassNotFoundException: com.telefonica.iot.cygnus.handlers.NGSIRestHandler
  73. at com.google.common.base.Throwables.propagate(Throwables.java:156)
  74. at org.apache.flume.source.http.HTTPSource.configure(HTTPSource.java:114)
  75. at org.apache.flume.conf.Configurables.configure(Configurables.java:41)
  76. at org.apache.flume.node.AbstractConfigurationProvider.loadSources(AbstractConfigurationProvider.java:331)
  77. at org.apache.flume.node.AbstractConfigurationProvider.getConfiguration(AbstractConfigurationProvider.java:102)
  78. at org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run(PollingPropertiesFileConfigurationProvider.java:140)
  79. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  80. at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
  81. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
  82. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
  83. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  84. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  85. at java.lang.Thread.run(Thread.java:748)
  86. Caused by: java.lang.ClassNotFoundException: com.telefonica.iot.cygnus.handlers.NGSIRestHandler
  87. at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
  88. at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
  89. at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338)
  90. at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
  91. at java.lang.Class.forName0(Native Method)
  92. at java.lang.Class.forName(Class.java:264)
  93. at org.apache.flume.source.http.HTTPSource.configure(HTTPSource.java:102)
  94. ... 11 more
  95. time=2018-04-30T14:24:00.841Z | lvl=INFO | corr=N/A | trans=N/A | srv=N/A | subsrv=N/A | comp=cygnus-ngsi | op=create | msg=org.apache.flume.sink.DefaultSinkFactory[40] : Creating instance of sink: mysql-sink, type: com.telefonica.iot.cygnus.sinks.NGSIMySQLSink
  96. time=2018-04-30T14:24:00.842Z | lvl=ERROR | corr=N/A | trans=N/A | srv=N/A | subsrv=N/A | comp=cygnus-ngsi | op=run | msg=org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable[142] : Failed to load configuration data. Exception follows.
  97. org.apache.flume.FlumeException: Unable to load sink type: com.telefonica.iot.cygnus.sinks.NGSIMySQLSink, class: com.telefonica.iot.cygnus.sinks.NGSIMySQLSink
  98. at org.apache.flume.sink.DefaultSinkFactory.getClass(DefaultSinkFactory.java:69)
  99. at org.apache.flume.sink.DefaultSinkFactory.create(DefaultSinkFactory.java:41)
  100. at org.apache.flume.node.AbstractConfigurationProvider.loadSinks(AbstractConfigurationProvider.java:415)
  101. at org.apache.flume.node.AbstractConfigurationProvider.getConfiguration(AbstractConfigurationProvider.java:103)
  102. at org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run(PollingPropertiesFileConfigurationProvider.java:140)
  103. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  104. at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
  105. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
  106. at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
  107. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
  108. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
  109. at java.lang.Thread.run(Thread.java:748)
  110. Caused by: java.lang.ClassNotFoundException: com.telefonica.iot.cygnus.sinks.NGSIMySQLSink
  111. at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
  112. at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
  113. at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338)
  114. at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
  115. at java.lang.Class.forName0(Native Method)
  116. at java.lang.Class.forName(Class.java:264)
  117. at org.apache.flume.sink.DefaultSinkFactory.getClass(DefaultSinkFactory.java:67)
  118. ... 11 more
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!