flink启动报错

骑猪看日落 2023-10-02 14:41 21阅读 0赞

#### 文章目录 ####

*   *  报错信息
     *  大概意思：

### 报错信息 ###

The program finished with the following exception:
    
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: JobManager memory configuration failed: The configured Total Flink Memory (64.000mb (67108864 bytes)) is less than the configured Off-heap Memory (128.000mb (134217728 bytes)).
    	at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
    	at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
    	at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114)
    	at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:812)
    	at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:246)
    	at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1054)
    	at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1132)
    	at java.base/java.security.AccessController.doPrivileged(Native Method)
    	at java.base/javax.security.auth.Subject.doAs(Subject.java:423)
    	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1698)
    	at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
    	at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1132)
    Caused by: org.apache.flink.configuration.IllegalConfigurationException: JobManager memory configuration failed: The configured Total Flink Memory (64.000mb (67108864 bytes)) is less than the configured Off-heap Memory (128.000mb (134217728 bytes)).
    	at org.apache.flink.runtime.jobmanager.JobManagerProcessUtils.processSpecFromConfigWithNewOptionToInterpretLegacyHeap(JobManagerProcessUtils.java:78)
    	at org.apache.flink.client.deployment.AbstractContainerizedClusterClientFactory.getClusterSpecification(AbstractContainerizedClusterClientFactory.java:43)
    	at org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor.execute(AbstractJobClusterExecutor.java:78)
    	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2043)
    	at org.apache.flink.client.program.StreamContextEnvironment.executeAsync(StreamContextEnvironment.java:137)
    	at org.apache.flink.client.program.StreamContextEnvironment.execute(StreamContextEnvironment.java:76)
    	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1917)
    	at myflink.SocketWindowWordCount.main(SocketWindowWordCount.java:32)
    	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
    	at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
    	... 11 more
    Caused by: org.apache.flink.configuration.IllegalConfigurationException: The configured Total Flink Memory (64.000mb (67108864 bytes)) is less than the configured Off-heap Memory (128.000mb (134217728 bytes)).
    	at org.apache.flink.runtime.util.config.memory.jobmanager.JobManagerFlinkMemoryUtils.deriveFromTotalFlinkMemory(JobManagerFlinkMemoryUtils.java:122)
    	at org.apache.flink.runtime.util.config.memory.jobmanager.JobManagerFlinkMemoryUtils.deriveFromTotalFlinkMemory(JobManagerFlinkMemoryUtils.java:36)
    	at org.apache.flink.runtime.util.config.memory.ProcessMemoryUtils.deriveProcessSpecWithTotalProcessMemory(ProcessMemoryUtils.java:119)
    	at org.apache.flink.runtime.util.config.memory.ProcessMemoryUtils.memoryProcessSpecFromConfig(ProcessMemoryUtils.java:84)
    	at org.apache.flink.runtime.jobmanager.JobManagerProcessUtils.processSpecFromConfig(JobManagerProcessUtils.java:83)
    	at org.apache.flink.runtime.jobmanager.JobManagerProcessUtils.processSpecFromConfigWithNewOptionToInterpretLegacyHeap(JobManagerProcessUtils.java:73)
    	... 23 more

### 大概意思： ###

JobManager内存配置失败：配置的Flink内存总量（64.000mb（67108864字节））小于配置的堆外内存（128.000mb（134217728字节））。

flink 进程内存模型：官网 [https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/deployment/memory/mem\_setup.html\#configure-total-memory][https_ci.apache.org_projects_flink_flink-docs-release-1.12_zh_deployment_memory_mem_setup.html_configure-total-memory]

![在这里插入图片描述][b5f6f870ac794de4aae38c0781a5ea71.png]

[https_ci.apache.org_projects_flink_flink-docs-release-1.12_zh_deployment_memory_mem_setup.html_configure-total-memory]: https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/deployment/memory/mem_setup.html#configure-total-memory
[b5f6f870ac794de4aae38c0781a5ea71.png]: https://img-blog.csdnimg.cn/b5f6f870ac794de4aae38c0781a5ea71.png