Guest User

Untitled

a guest
Jul 3rd, 2018
84
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 14.09 KB | None | 0 0
  1. 2018-07-03 19:09:45,101 DEBUG org.apache.flink.runtime.rest.RestClient - Sending request of class class org.apache.flink.runtime.rest.messages.EmptyRequestBody to localhost:8080/jobs/84409012eaf1b3fbd7fae9ef0918f9d8?mode=cancel
  2. 2018-07-03 19:09:45,103 ERROR org.apache.flink.runtime.rest.RestClient - Response was not valid JSON.
  3. org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParseException: Unrecognized token 'java': was expecting ('true', 'false' or 'null')
  4. at [Source: org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufInputStream@4c35d4db; line: 1, column: 6]
  5. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:1586)
  6. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:521)
  7. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._reportInvalidToken(UTF8StreamJsonParser.java:3464)
  8. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._handleUnexpectedValue(UTF8StreamJsonParser.java:2628)
  9. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._nextTokenNotInObject(UTF8StreamJsonParser.java:854)
  10. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser.nextToken(UTF8StreamJsonParser.java:748)
  11. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._initForReading(ObjectMapper.java:3847)
  12. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:3792)
  13. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper.readTree(ObjectMapper.java:2272)
  14. at org.apache.flink.runtime.rest.RestClient$ClientHandler.readRawResponse(RestClient.java:288)
  15. at org.apache.flink.runtime.rest.RestClient$ClientHandler.channelRead0(RestClient.java:251)
  16. at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
  17. at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
  18. at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
  19. at org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
  20. at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
  21. at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
  22. at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
  23. at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:147)
  24. at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
  25. at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
  26. at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
  27. at org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
  28. at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
  29. at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
  30. at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
  31. at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
  32. at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
  33. at org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
  34. at java.lang.Thread.run(Thread.java:748)
  35. 2018-07-03 19:09:45,105 ERROR org.apache.flink.runtime.rest.RestClient - Unexpected plain-text response: java.io.IOException: Unsupported HTTP method: PATCH
  36. at org.apache.flink.runtime.webmonitor.HttpRequestHandler.channelRead0(HttpRequestHandler.java:114)
  37. at org.apache.flink.runtime.webmonitor.HttpRequestHandler.channelRead0(HttpRequestHandler.java:65)
  38. at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
  39. at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
  40. at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
  41. at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
  42. at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
  43. at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
  44. at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
  45. at io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:147)
  46. at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
  47. at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
  48. at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
  49. at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
  50. at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
  51. at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
  52. at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
  53. at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
  54. at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
  55. at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
  56. at java.lang.Thread.run(Thread.java:748)
  57.  
  58. 2018-07-03 19:09:48,106 INFO org.apache.flink.runtime.rest.RestClient - Shutting down rest endpoint.
  59. 2018-07-03 19:09:48,106 DEBUG org.apache.flink.runtime.rest.RestClient - Sending request of class class org.apache.flink.runtime.rest.messages.EmptyRequestBody to localhost:8080/jobs/84409012eaf1b3fbd7fae9ef0918f9d8?mode=cancel
  60. 2018-07-03 19:09:49,110 INFO org.apache.flink.runtime.rest.RestClient - Rest endpoint shutdown complete.
  61. 2018-07-03 19:09:49,117 WARN org.apache.flink.table.client.cli.CliClient - Could not execute SQL statement.
  62. org.apache.flink.table.client.gateway.SqlExecutionException: Could not retrieve or create a cluster.
  63. at org.apache.flink.table.client.gateway.local.LocalExecutor.deployJob(LocalExecutor.java:432)
  64. at org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeQueryInternal$1(LocalExecutor.java:362)
  65. at org.apache.flink.table.client.gateway.local.CollectStreamResult$JobMonitoringThread.run(CollectStreamResult.java:146)
  66. Caused by: org.apache.flink.client.program.ProgramInvocationException: Could not retrieve the execution result.
  67. at org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClusterClient.java:258)
  68. at org.apache.flink.table.client.gateway.local.LocalExecutor.deployJob(LocalExecutor.java:429)
  69. ... 2 more
  70. Caused by: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
  71. at org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$5(RestClusterClient.java:357)
  72. at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:870)
  73. at java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:852)
  74. at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
  75. at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
  76. at org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$5(FutureUtils.java:214)
  77. at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
  78. at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
  79. at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
  80. at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
  81. at org.apache.flink.runtime.rest.RestClient$ClientHandler.readRawResponse(RestClient.java:300)
  82. at org.apache.flink.runtime.rest.RestClient$ClientHandler.channelRead0(RestClient.java:251)
  83. at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
  84. at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
  85. at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
  86. at org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
  87. at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
  88. at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
  89. at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:288)
  90. at org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpClientCodec$Decoder.channelInactive(HttpClientCodec.java:212)
  91. at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelInactive(CombinedChannelDuplexHandler.java:132)
  92. at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:237)
  93. at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:223)
  94. at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:829)
  95. at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AbstractUnsafe$7.run(AbstractChannel.java:610)
  96. at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:357)
  97. at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:357)
  98. at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
  99. at org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
  100. at java.lang.Thread.run(Thread.java:748)
  101. Caused by: java.util.concurrent.CompletionException: org.apache.flink.runtime.concurrent.FutureUtils$RetryException: Could not complete the operation. Number of retries has been exhausted.
  102. at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
  103. at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
  104. at java.util.concurrent.CompletableFuture.biApply(CompletableFuture.java:1088)
  105. at java.util.concurrent.CompletableFuture$BiApply.tryFire(CompletableFuture.java:1070)
  106. ... 27 more
  107. Caused by: org.apache.flink.runtime.concurrent.FutureUtils$RetryException: Could not complete the operation. Number of retries has been exhausted.
  108. ... 25 more
  109. Caused by: java.util.concurrent.CompletionException: org.apache.flink.runtime.rest.util.RestClientException: Response was not valid JSON, but plain-text: Failure: 404 Not Found
  110.  
  111. at java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326)
  112. at java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338)
  113. at java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911)
  114. at java.util.concurrent.CompletableFuture$UniRelay.tryFire(CompletableFuture.java:899)
  115. ... 22 more
  116. Caused by: org.apache.flink.runtime.rest.util.RestClientException: Response was not valid JSON, but plain-text: Failure: 404 Not Found
  117.  
  118. ... 20 more
  119. Caused by: org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParseException: Unrecognized token 'Failure': was expecting ('true', 'false' or 'null')
  120. at [Source: org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufInputStream@5fc7a8ef; line: 1, column: 9]
  121. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:1586)
  122. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:521)
  123. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._reportInvalidToken(UTF8StreamJsonParser.java:3464)
  124. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._handleUnexpectedValue(UTF8StreamJsonParser.java:2628)
  125. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._nextTokenNotInObject(UTF8StreamJsonParser.java:854)
  126. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser.nextToken(UTF8StreamJsonParser.java:748)
  127. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._initForReading(ObjectMapper.java:3847)
  128. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:3792)
  129. at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper.readTree(ObjectMapper.java:2272)
  130. at org.apache.flink.runtime.rest.RestClient$ClientHandler.readRawResponse(RestClient.java:288)
  131. ... 19 more
Add Comment
Please, Sign In to add comment