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-


回复