мы получили ответ об ошибке {"errors": ["Internal server error: null"]} при загрузке jar на сервер Flink 1.5.0 с помощью клиента REST java.Тот же код работает должным образом в Flink 1.4.2.Фактически мы можем видеть, что банка была загружена из графического интерфейса Flink.Но неправильная логика нарушения статуса.Любой совет, пожалуйста?
HttpPost uploadFile = new HttpPost(flinkJobManagerUrl + "/jars/upload");
MultipartEntityBuilder builder = MultipartEntityBuilder.create();
builder.addBinaryBody(
"jarfile",
new FileInputStream(f),
ContentType.create("application/x-java-archive"),
f.getName()
);
HttpEntity multipart = builder.build();
uploadFile.setEntity(multipart);
CloseableHttpResponse response = restClient.execute(uploadFile);
rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
================================ *
Ошибка из журнала JM:
018-06-01 16: 05: 46,514 WARN org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - необработанное исключение org.apache.flink.shaded.netty4.io.netty.handler.codec.http.multipart.HttpPostRequestDecoder $ EndOfDataDecoderException по адресу org.apache.flink.shaded.netty4.io.netty.handler.codec.http.multipart.HttpPostMultipartRequestDecoder.hasNext (HttpPostMultipartRequestDap.haj.tjlink.6) .jj4.io.netty.handler.codec.http.multipart.HttpPostRequestDecoder.hasNext (HttpPostRequestDecoder.java:241) в org.apache.flink.runtime.rest.FileUploadHandler.channelRead0 (FileUploadHandler.java:)runtime.rest.FileUploadHandler.channelRead0 (FileUploadHandler.java:51) в org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead (SimpleChannelInboundHandler.java:105) в org.apache.f.shanetty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead (AbstractChannelHandlerContext.java:339) по адресу org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead (AbstractChannelHandlerContext.java:324.link.hag). org.netty.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead (AbstractChannelHandlerContext.java:339) в org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead (AbstractChannel) (или класс).apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline.fireChannelRead (DefaultChannelPipeline.java:847) в org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioByteChannel $ NioByteUnsafe.read (Аннотация.java: 131) в орг.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey (NioEventLoop.java:511) в org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized (NioEvent.java: 468) по адресу org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys (NioEventLoop.java:382) по адресу org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run (NioEventLoop.java:354) в org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor $ 2.run (SingleThreadEventExecutor.java:111) в org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultThreadFactory $ DefaultRunnableDecorator.run (DefaultThreadFactory.java:137) в java.lang.Thread.run (Thread.java:748)
Но посленекоторое время вы увидите банку, загруженную из графического интерфейса.Но затем при запуске он выдаст другое исключение:
2018-06-01 16: 10: 06,752 ОШИБКА org.apache.flink.runtime.webmonitor.handlers.JarRunHandler - Возникла исключительная ситуация в обработчике REST.org.apache.flink.runtime.rest.handler.RestHandlerException: ожидаемое только одно значение [--KAFKA_IN a_O@192.168.56.120: 9092, 192.168.56.121:9092, 192.168.56.122:9092/a_O_124 --ZK_SESSION_TIME 600E1].в org.apache.flink.runtime.rest.handler.util.HandlerRequestUtils.getQueryParameter (HandlerRequestUtils.java:56) в org.apache.flink.runtime.rest.handler.util.HandlerRequestUtils.getQueryParameter (HandlerReavaestUtil)в org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.handleRequest (JarRunHandler.java:102) в org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.handleRequest (JarRunHandler.java:68).flink.runtime.rest.handler.AbstractRestHandler.respondToRequest (AbstractRestHandler.java:77) в org.apache.flink.runtime.rest.AbstractHandler.respondAsLeader (AbstractHandler.java:168) в org.apache.flink.runtime.rest.handler.736) в java.util.concurrent.CompletableFuture $ Completion.run (CompletableFuture.java:442) в org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks (SingleThreadEventExec77): jв org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run (NioEventLoop.java:357) в org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor $ 2.run (SingleThreadEventExecutor.java:111) в org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultThreadFactory $ DefaultRunnableDecorator.un(DefaultThreadFactory.java:137) в java.lang.Thread.run (Thread.java:748)