代码之家 › 专栏 › 技术社区 › madhead

Apache Flink的最大容量

fatjar shadowjar apache-flink

madhead · 技术社区 · 6 年前

我已经构建了一个Apache Flink应用程序,并将其打包在一个大罐子中 Gradle Shadow Plugin

$ curl -X POST -H "Expect:" -i -F "jarfile=@flink-all.jar" http://ec2-18-204-247-166.compute-1.amazonaws.com:8081/jars/upload

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

那么,有什么选择呢?

我能看到罐子在里面 /tmp/flink-web-UUID/flink-web-upload/UUID/flink-all.jar

1 回复 | 直到 6 年前

madhead 6 年前

好吧,很容易修复。

首先,我扫描了他们的回购协议,发现“太大”的字符串 this class . 看起来像 SERVER_MAX_CONTENT_LENGTH here 从配置选项 rest.server.max-content-length . 默认值为100 MiB。

设置在里面 flink-conf.yaml 到 209715200

推荐文章

Ellen Spertus · 使用Scala访问HBase的推荐方法

7 年前

skrshn · JAVA尝试在Flink中创建Kafka使用者时出现lang.NoClassDefFoundError(CheckpointedRestoring)

7 年前

Daniel · 目录中的Apache Flink流文件

7 年前

Christos Hadjinikolis · Flink:执行管道java时出错。util。同时发生的TimeoutException:期货在[10000毫秒]后超时

7 年前

Mustafa · Apache Flink:自定义InputFormat仅以1的并行度运行

7 年前

Soheil Pourbafrani · Apache Flink-org的类文件。阿帕奇。弗林克。流式处理。api。斯卡拉。找不到数据流

7 年前

Jicaar · 一个卡夫卡制作人可以被多个接收器安全使用吗?

7 年前

Christos Hadjinikolis · Flink JobExecutionException:akka。客户超时

7 年前

Christos Hadjinikolis · Flink IOException:网络缓冲区数量不足

7 年前

Brutal_JL · flink ReduceFunction的默认触发器是什么?

7 年前