• flink web-ui提交New Job报错Server Response Message: Internal server error.


    报错:在flink web-ui提交New Job报错Server Response Message: Internal server error.

    在这里插入图片描述
    查看日志

    Caused by: org.apache.flink.client.program.ProgramInvocationException: The program's entry point class 'WordCountScalaStream' was not found in the jar file.
            at org.apache.flink.client.program.PackagedProgram.loadMainClass(PackagedProgram.java:389) ~[flink-dist_2.12-1.11.1.jar:1.11.1]
            at org.apache.flink.client.program.PackagedProgram.(PackagedProgram.java:139) ~[flink-dist_2.12-1.11.1.jar:1.11.1]
            at org.apache.flink.client.program.PackagedProgram.(PackagedProgram.java:61) ~[flink-dist_2.12-1.11.1.jar:1.11.1]
            at org.apache.flink.client.program.PackagedProgram$Builder.build(PackagedProgram.java:557) ~[flink-dist_2.12-1.11.1.jar:1.11.1]
            at org.apache.flink.runtime.webmonitor.handlers.utils.JarHandlerUtils$JarHandlerContext.toPackagedProgram(JarHandlerUtils.java:156) ~[flink-dist_2.12-1.11.1.jar:1.11.1]
            ... 50 more
    Caused by: java.lang.ClassNotFoundException: WordCountScalaStream
            at java.net.URLClassLoader.findClass(URLClassLoader.java:382) ~[?:1.8.0_231]
            at java.lang.ClassLoader.loadClass(ClassLoader.java:418) ~[?:1.8.0_231]
            at org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:61) ~[flink-dist_2.12-1.11.1.jar:1.11.1]
            at org.apache.flink.util.ChildFirstClassLoader.loadClassWithoutExceptionHandling(ChildFirstClassLoader.java:74) ~[flink-dist_2.12-1.11.1.jar:1.11.1]
            at org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:48) ~[flink-dist_2.12-1.11.1.jar:1.11.1]
            at java.lang.ClassLoader.loadClass(ClassLoader.java:351) ~[?:1.8.0_231]
            at java.lang.Class.forName0(Native Method) ~[?:1.8.0_231]
            at java.lang.Class.forName(Class.java:348) ~[?:1.8.0_231]
            at org.apache.flink.client.program.PackagedProgram.loadMainClass(PackagedProgram.java:387) ~[flink-dist_2.12-1.11.1.jar:1.11.1]
            at org.apache.flink.client.program.PackagedProgram.(PackagedProgram.java:139) ~[flink-dist_2.12-1.11.1.jar:1.11.1]
            at org.apache.flink.client.program.PackagedProgram.(PackagedProgram.java:61) ~[flink-dist_2.12-1.11.1.jar:1.11.1]
            at org.apache.flink.client.program.PackagedProgram$Builder.build(PackagedProgram.java:557) ~[flink-dist_2.12-1.11.1.jar:1.11.1]
            at org.apache.flink.runtime.webmonitor.handlers.utils.JarHandlerUtils$JarHandlerContext.toPackagedProgram(JarHandlerUtils.java:156) ~[flink-dist_2.12-1.11.1.jar:1.11.1]
            ... 50 more
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22

    原因:maven打包时未打包scala程序

    解决方案:在pom.xml加入maven-scala-plugin打包插件

            
                
                
                    org.apache.maven.plugins
                    maven-shade-plugin
                    2.4.3
                    
                        
                            package
                            
                                shade
                            
                            
                                
                                    
                                        *:*
                                        
                                            META-INF/*.SF
                                            META-INF/*.DSA
                                            META-INF/*.RSA
                                        
                                    
                                
                            
                        
                    
                
                
                    org.scala-tools
                    maven-scala-plugin
                    2.12.2
                    
                        
                            
                                compile
                                testCompile
                            
                        
                    
                
            
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41

    重新打包,然后上传到flink的web-ui,问题解决
    在这里插入图片描述

  • 相关阅读:
    阿里巴巴技术官甩出的SpringCloud笔记,GitHub标星已突破82k
    成熟ICT测试系统与LabVIEW定制开发的比较
    DeepLinQ 用于隐私保护的数据共享的分布式多层分类账本
    反射_数据结构
    Android OpenGL ES 总结之FBO
    【ARM AMBA AXI 入门 16 - AXI 写响应通道 BVALID | BREADY | BRESP 详细介绍】
    台湾大学李宏毅:图解卷积神经网络CNN
    【LeetCode每日一题合集】2023.9.11-2023.9.17(⭐反悔贪心&拓扑排序&Floyd)
    【智能产品方案】智能跳绳方案开发
    前端学习记录~2023.8.19~JavaScript重难点实例精讲~第7章 ES6(2)
  • 原文地址:https://blog.csdn.net/qq_41413743/article/details/126591301