Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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
- 2018-07-03 19:09:45,103 ERROR org.apache.flink.runtime.rest.RestClient - Response was not valid JSON.
- org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParseException: Unrecognized token 'java': was expecting ('true', 'false' or 'null')
- at [Source: org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufInputStream@4c35d4db; line: 1, column: 6]
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:1586)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:521)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._reportInvalidToken(UTF8StreamJsonParser.java:3464)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._handleUnexpectedValue(UTF8StreamJsonParser.java:2628)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._nextTokenNotInObject(UTF8StreamJsonParser.java:854)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser.nextToken(UTF8StreamJsonParser.java:748)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._initForReading(ObjectMapper.java:3847)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:3792)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper.readTree(ObjectMapper.java:2272)
- at org.apache.flink.runtime.rest.RestClient$ClientHandler.readRawResponse(RestClient.java:288)
- at org.apache.flink.runtime.rest.RestClient$ClientHandler.channelRead0(RestClient.java:251)
- at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
- at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
- at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
- at org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
- at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
- at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
- at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
- at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:147)
- at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
- at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
- at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
- at org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
- at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
- at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
- at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
- at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
- at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
- at org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
- at java.lang.Thread.run(Thread.java:748)
- 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
- at org.apache.flink.runtime.webmonitor.HttpRequestHandler.channelRead0(HttpRequestHandler.java:114)
- at org.apache.flink.runtime.webmonitor.HttpRequestHandler.channelRead0(HttpRequestHandler.java:65)
- at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
- at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
- at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
- at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
- at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
- at io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:147)
- at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
- at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
- at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
- at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
- at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
- at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
- at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
- at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
- at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
- at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
- at java.lang.Thread.run(Thread.java:748)
- 2018-07-03 19:09:48,106 INFO org.apache.flink.runtime.rest.RestClient - Shutting down rest endpoint.
- 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
- 2018-07-03 19:09:49,110 INFO org.apache.flink.runtime.rest.RestClient - Rest endpoint shutdown complete.
- 2018-07-03 19:09:49,117 WARN org.apache.flink.table.client.cli.CliClient - Could not execute SQL statement.
- org.apache.flink.table.client.gateway.SqlExecutionException: Could not retrieve or create a cluster.
- at org.apache.flink.table.client.gateway.local.LocalExecutor.deployJob(LocalExecutor.java:432)
- at org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeQueryInternal$1(LocalExecutor.java:362)
- at org.apache.flink.table.client.gateway.local.CollectStreamResult$JobMonitoringThread.run(CollectStreamResult.java:146)
- Caused by: org.apache.flink.client.program.ProgramInvocationException: Could not retrieve the execution result.
- at org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClusterClient.java:258)
- at org.apache.flink.table.client.gateway.local.LocalExecutor.deployJob(LocalExecutor.java:429)
- ... 2 more
- Caused by: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
- at org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$5(RestClusterClient.java:357)
- at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:870)
- at java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:852)
- at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
- at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
- at org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$5(FutureUtils.java:214)
- at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
- at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
- at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
- at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
- at org.apache.flink.runtime.rest.RestClient$ClientHandler.readRawResponse(RestClient.java:300)
- at org.apache.flink.runtime.rest.RestClient$ClientHandler.channelRead0(RestClient.java:251)
- at org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
- at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
- at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
- at org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
- at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
- at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
- at org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:288)
- at org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpClientCodec$Decoder.channelInactive(HttpClientCodec.java:212)
- at org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelInactive(CombinedChannelDuplexHandler.java:132)
- at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:237)
- at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:223)
- at org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:829)
- at org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AbstractUnsafe$7.run(AbstractChannel.java:610)
- at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:357)
- at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:357)
- at org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
- at org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: java.util.concurrent.CompletionException: org.apache.flink.runtime.concurrent.FutureUtils$RetryException: Could not complete the operation. Number of retries has been exhausted.
- at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
- at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
- at java.util.concurrent.CompletableFuture.biApply(CompletableFuture.java:1088)
- at java.util.concurrent.CompletableFuture$BiApply.tryFire(CompletableFuture.java:1070)
- ... 27 more
- Caused by: org.apache.flink.runtime.concurrent.FutureUtils$RetryException: Could not complete the operation. Number of retries has been exhausted.
- ... 25 more
- 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
- at java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326)
- at java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338)
- at java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911)
- at java.util.concurrent.CompletableFuture$UniRelay.tryFire(CompletableFuture.java:899)
- ... 22 more
- Caused by: org.apache.flink.runtime.rest.util.RestClientException: Response was not valid JSON, but plain-text: Failure: 404 Not Found
- ... 20 more
- Caused by: org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParseException: Unrecognized token 'Failure': was expecting ('true', 'false' or 'null')
- at [Source: org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufInputStream@5fc7a8ef; line: 1, column: 9]
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:1586)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:521)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._reportInvalidToken(UTF8StreamJsonParser.java:3464)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._handleUnexpectedValue(UTF8StreamJsonParser.java:2628)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._nextTokenNotInObject(UTF8StreamJsonParser.java:854)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser.nextToken(UTF8StreamJsonParser.java:748)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._initForReading(ObjectMapper.java:3847)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:3792)
- at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper.readTree(ObjectMapper.java:2272)
- at org.apache.flink.runtime.rest.RestClient$ClientHandler.readRawResponse(RestClient.java:288)
- ... 19 more
Add Comment
Please, Sign In to add comment