• 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,问题解决
    在这里插入图片描述

  • 相关阅读:
    Springboot结合Mockito写单元测试实践和原理
    Azure DevOps Server 设置项目管理用户,用户组
    Java面向对象
    Dokcer搭建Apache Guacamole堡垒机
    外贸人必备的跨境电商常见专有名词!
    在Ubuntu上安装LibRaw
    免编程经验,搭建宠物店小程序轻松实现
    【ESP8266点焊机】基于 ESP8266 for Arduino
    游戏建模与动画建模的区别,小白学建模前一定要知道
    腾讯二面 高级Java开发工程师
  • 原文地址:https://blog.csdn.net/qq_41413743/article/details/126591301