flink 1.6.0作业jar上载大小限制

gfttwv5a  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(624)

job jar文件大小限制是多少?有没有可能覆盖它?
随着flink 1.6.0的推出,以及完全重新整理的作业提交,我尝试上传jar,比如:

$ curl http://localhost:8081/jars/upload -X POST -F "jarfile=@word-count-beam/target/word-count-beam-bundled-0.1.jar" --verbose
Note: Unnecessary use of -X or --request, POST is already inferred.

* Trying ::1...
* TCP_NODELAY set
* Connected to localhost (::1) port 8081 (#0)

> POST /jars/upload HTTP/1.1
> Host: localhost:8081
> User-Agent: curl/7.54.0
> Accept: */*
> Content-Length: 108716165
> Expect: 100-continue
> Content-Type: multipart/form-data; boundary=------------------------ab44aa4cd2db3c75
> 

* Done waiting for 100-continue

< HTTP/1.1 413 Request Entity Too Large
< content-length: 0

* HTTP error before end of send, stop sending

< 

* Closing connection 0

但我得到:

413 Request Entity Too Large

实际jar文件大小为:

$ du -h word-count-beam/target/word-count-beam-bundled-0.1.jar
113M    word-count-beam/target/word-count-beam-bundled-0.1.jar

我在码头用 1.6.0-scala_2.11 形象。
更新:尝试从web ui上载时也是这样:

注意:jar上传特性与flink1.5(docker)一起使用。

o75abkj4

o75abkj41#

@robosoul,我认为在配置中有一个rest限制,默认情况下最大大小是104857600字节,看起来你超出了限制

相关问题