Hi！ 看起来你本机的 8081 端口已经有别的程序占用了。能否在浏览器访问 localhost:8081，确认一下打开的是 Flink web UI 吗？
如果跑的是 Flink standalone cluster，需要先启动 standalone cluster。进入 flink 目录，运行 bin/start-cluster.sh 即可启动。 [email protected] <[email protected]> 于2021年12月29日周三 09:48写道： > Hi，Flink您好 > 我在集成Hive时，通过sql-client连接Hive成功，但在查询hive表时，总是提示以下错误，请问我该怎么办？ > > 我的环境是CDH6.3.1，Flink1.13.2和1.14.2均尝试，按照官方指导一步步配置，均报相同错误。您的指导对我至关重要，期待您的回复，谢谢 > 2021-12-28 20:33:42,999 WARN > org.apache.flink.client.program.rest.RestClusterClient [] - Attempt > to submit job 'collect' (3ef21e6c1235316899b83d491a9c363a) to ' > http://localhost:8081' has failed. > java.util.concurrent.CompletionException: > org.apache.flink.runtime.rest.util.RestClientException: Response was not > valid JSON, but plain-text: Login error. Need username and password > at > java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326) > ~[?:1.8.0_221] > at > java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338) > ~[?:1.8.0_221] > at > java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911) > ~[?:1.8.0_221] > at > java.util.concurrent.CompletableFuture$UniRelay.tryFire(CompletableFuture.java:899) > ~[?:1.8.0_221] > at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) > [?:1.8.0_221] > at > java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) > [?:1.8.0_221] > at > org.apache.flink.runtime.rest.RestClient$ClientHandler.readRawResponse(RestClient.java:680) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.runtime.rest.RestClient$ClientHandler.channelRead0(RestClient.java:613) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:383) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:354) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpClientCodec$Decoder.channelInactive(HttpClientCodec.java:311) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelInactive(CombinedChannelDuplexHandler.java:221) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:241) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1405) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:901) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AbstractUnsafe$8.run(AbstractChannel.java:831) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:497) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at java.lang.Thread.run(Thread.java:748) [?:1.8.0_221] > Caused by: org.apache.flink.runtime.rest.util.RestClientException: > Response was not valid JSON, but plain-text: Login error. Need username and > password > at > org.apache.flink.runtime.rest.RestClient$ClientHandler.readRawResponse(RestClient.java:684) > ~[flink-dist_2.11-1.14.2.jar:1.14.2] > ... 33 more > Caused by: > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParseException: > Unrecognized token 'Login': was expecting (JSON String, Number, Array, > Object or token 'null', 'true' or 'false') > at [Source: > (org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufInputStream); line: > 1, column: 7] > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:2337) > ~[flink-shaded-jackson-2.12.4-14.0.jar:2.12.4-14.0] > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:720) > ~[flink-shaded-jackson-2.12.4-14.0.jar:2.12.4-14.0] > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._reportInvalidToken(UTF8StreamJsonParser.java:3593) > ~[flink-shaded-jackson-2.12.4-14.0.jar:2.12.4-14.0] > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._handleUnexpectedValue(UTF8StreamJsonParser.java:2688) > ~[flink-shaded-jackson-2.12.4-14.0.jar:2.12.4-14.0] > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser._nextTokenNotInObject(UTF8StreamJsonParser.java:870) > ~[flink-shaded-jackson-2.12.4-14.0.jar:2.12.4-14.0] > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.json.UTF8StreamJsonParser.nextToken(UTF8StreamJsonParser.java:762) > ~[flink-shaded-jackson-2.12.4-14.0.jar:2.12.4-14.0] > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._readTreeAndClose(ObjectMapper.java:4622) > ~[flink-shaded-jackson- > > >
