API tools faq
paste
Guest User

Untitled

a guest
Oct 18th, 2017
81
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 8.46 KB | None | 0 0
raw download clone embed print report
  1. {
  2. "unitTime": "2017-10-12T11:49:14+0900",
  3. "equipment": "F",
  4. "data": [
  5. {
  6. "subdata": "b"
  7. }
  8. ]
  9. }
  10.  
  11. java.lang.NullPointerException
  12. at java.util.Calendar.setTime(Calendar.java:1770)
  13. at java.text.SimpleDateFormat.format(SimpleDateFormat.java:943)
  14. at java.text.SimpleDateFormat.format(SimpleDateFormat.java:936)
  15. at java.text.DateFormat.format(DateFormat.java:345)
  16. at com.google.gson.DefaultDateTypeAdapter.write(DefaultDateTypeAdapter.java:88)
  17. at com.google.gson.DefaultDateTypeAdapter.write(DefaultDateTypeAdapter.java:40)
  18. at com.google.gson.internal.bind.TypeAdapterRuntimeTypeWrapper.write(TypeAdapterRuntimeTypeWrapper.java:69)
  19. at com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$1.write(ReflectiveTypeAdapterFactory.java:125)
  20. at com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$Adapter.write(ReflectiveTypeAdapterFactory.java:243)
  21. at com.google.gson.internal.bind.ObjectTypeAdapter.write(ObjectTypeAdapter.java:107)
  22. at com.google.gson.internal.bind.TypeAdapterRuntimeTypeWrapper.write(TypeAdapterRuntimeTypeWrapper.java:69)
  23. at com.google.gson.internal.bind.CollectionTypeAdapterFactory$Adapter.write(CollectionTypeAdapterFactory.java:97)
  24. at com.google.gson.internal.bind.CollectionTypeAdapterFactory$Adapter.write(CollectionTypeAdapterFactory.java:61)
  25. at com.google.gson.internal.bind.TypeAdapterRuntimeTypeWrapper.write(TypeAdapterRuntimeTypeWrapper.java:69)
  26. at com.google.gson.internal.bind.MapTypeAdapterFactory$Adapter.write(MapTypeAdapterFactory.java:208)
  27. at com.google.gson.internal.bind.MapTypeAdapterFactory$Adapter.write(MapTypeAdapterFactory.java:145)
  28. at com.google.gson.Gson.toJson(Gson.java:669)
  29. at com.google.gson.Gson.toJson(Gson.java:648)
  30. at com.google.gson.Gson.toJson(Gson.java:603)
  31. at com.google.gson.Gson.toJson(Gson.java:583)
  32. at io.searchbox.action.AbstractAction.getData(AbstractAction.java:167)
  33. at io.searchbox.core.Bulk.getData(Bulk.java:102)
  34. at io.searchbox.client.http.JestHttpClient.prepareRequest(JestHttpClient.java:115)
  35. at io.searchbox.client.http.JestHttpClient.execute(JestHttpClient.java:64)
  36. at io.searchbox.client.http.JestHttpClient.execute(JestHttpClient.java:60)
  37. at com.example.testcb.databus.RealTimeDataSink.saveToElasticSearch(RealTimeDataSink.java:94)
  38. at com.example.testcb.databus.RealTimeDataSink.productionMessageSink(RealTimeDataSink.java:61)
  39. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  40. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  41. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  42. at java.lang.reflect.Method.invoke(Method.java:498)
  43. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:180)
  44. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:112)
  45. at org.springframework.cloud.stream.binding.StreamListenerMessageHandler.handleRequestMessage(StreamListenerMessageHandler.java:48)
  46. at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:109)
  47. at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127)
  48. at org.springframework.cloud.stream.binding.DispatchingStreamListenerMessageHandler$ConditionalStreamListenerHandler.handleMessage(DispatchingStreamListenerMessageHandler.java:122)
  49. at org.springframework.cloud.stream.binding.DispatchingStreamListenerMessageHandler.handleRequestMessage(DispatchingStreamListenerMessageHandler.java:75)
  50. at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:109)
  51. at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127)
  52. at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:116)
  53. at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:148)
  54. at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:121)
  55. at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:89)
  56. at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:425)
  57. at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:375)
  58. at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115)
  59. at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45)
  60. at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105)
  61. at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutput(AbstractMessageProducingHandler.java:360)
  62. at org.springframework.integration.handler.AbstractMessageProducingHandler.produceOutput(AbstractMessageProducingHandler.java:271)
  63. at org.springframework.integration.handler.AbstractMessageProducingHandler.sendOutputs(AbstractMessageProducingHandler.java:188)
  64. at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:115)
  65. at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127)
  66. at org.springframework.integration.channel.FixedSubscriberChannel.send(FixedSubscriberChannel.java:70)
  67. at org.springframework.integration.channel.FixedSubscriberChannel.send(FixedSubscriberChannel.java:64)
  68. at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:115)
  69. at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:45)
  70. at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:105)
  71. at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:188)
  72. at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$000(KafkaMessageDrivenChannelAdapter.java:54)
  73. at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:288)
  74. at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:279)
  75. at org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter$1.doWithRetry(RetryingAcknowledgingMessageListenerAdapter.java:79)
  76. at org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter$1.doWithRetry(RetryingAcknowledgingMessageListenerAdapter.java:73)
  77. at org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:287)
  78. at org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:180)
  79. at org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter.onMessage(RetryingAcknowledgingMessageListenerAdapter.java:73)
  80. at org.springframework.kafka.listener.adapter.RetryingAcknowledgingMessageListenerAdapter.onMessage(RetryingAcknowledgingMessageListenerAdapter.java:39)
  81. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:794)
  82. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:738)
  83. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.access$2200(KafkaMessageListenerContainer.java:245)
  84. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer$ListenerInvoker.run(KafkaMessageListenerContainer.java:1031)
  85. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
  86. at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  87. at java.lang.Thread.run(Thread.java:748)
  88.  
  89. boolean indexExists = jestClient.execute(new IndicesExists.Builder(INDEX_NAME + "_" + today).build()).isSucceeded();
  90.  
  91. try {
  92. Bulk.Builder bulkIndexBuilder = new Bulk.Builder();
  93. for(Object object : outputs) {
  94. bulkIndexBuilder.addAction(new Index.Builder(object).index(INDEX_NAME + "_" + today).type(type).build());
  95. }
  96. jestClient.execute(bulkIndexBuilder.build());
  97.  
  98. } catch(NullPointerException e) {
  99. e.printStackTrace();
  100. }
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!