【一天一坑系列】SpringCloud微服务项目本地可以正常启动，但在Flink中却无法启动，莫名其妙？？？？

深碍√TFBOYSˉ_ 2023-01-17 13:53 129阅读 0赞

# 热门系列： #

*  ###   [程序人生，精彩抢先看][Link 1] ###

--------------------

# 1.前言 #

今天启动测试环境的一个实时计算服务。。该服务是使用Flink结合启动的。但是，偏偏出现了如题的问题！

于是开始查看flink打印日志。爆出了如下错误：

org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
    	at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:110)
    	at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:76)
    	at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:192)
    	at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:186)
    	at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:180)
    	at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:484)
    	at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:380)
    	at sun.reflect.GeneratedMethodAccessor55.invoke(Unknown Source)
    	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    	at java.lang.reflect.Method.invoke(Method.java:498)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:279)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:194)
    	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
    	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
    	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
    	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
    	at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
    	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
    	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
    	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
    	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
    	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
    	at akka.actor.Actor.aroundReceive(Actor.scala:517)
    	at akka.actor.Actor.aroundReceive$(Actor.scala:515)
    	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
    	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
    	at akka.actor.ActorCell.invoke(ActorCell.scala:561)
    	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
    	at akka.dispatch.Mailbox.run(Mailbox.scala:225)
    	at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
    	at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    	at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    	at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    	at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
    Caused by: java.lang.NoClassDefFoundError: Could not initialize class xxx.xxx.xxx.xxx_calc.factory.ApplicationContextFactory
    	at xxx.xxx.xxx.lifecycle_calc.sink.MysqlSink.open(MysqlSink.java:34)
    	at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
    	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
    	at org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:48)
    	at org.apache.flink.streaming.runtime.tasks.StreamTask.initializeStateAndOpen(StreamTask.java:1007)
    	at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$0(StreamTask.java:454)
    	at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:94)
    	at org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:449)
    	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:461)
    	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:707)
    	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:532)
    	at java.lang.Thread.run(Thread.java:748)

--------------------

# 2.正文 #

## 2.1 问题分析 ##

1.一开始以为是项目文件有错误代码，于是开始查看这个报错的类ApplicationContextFactory，但是相应的配置都没有问题。并且相较于上一个版本，只是加了一行打印日志！所以，应该不是文件类的原因！！！

2.查看flink配置，看看是否有人改动过导致的。但是查看相关文件的日期，都是很久之前的！所以，flink问题也排除！

3.包结构问题。但是本地项目又可以正常启动，说明包应该没啥问题！

## 2.2 解决问题 ##

感觉莫名其妙之际，想着使用之前的备份包试试。。结果，以前的备份包能正常启动。。而包的代码对比，只有多了一行打印日志，所以，问题可能出现在**打包环节**！

通过包文件对比，以及查看项目文件的一些改动之处，最后定位到问题出现在pom.xml文件中的一个配置上：

<plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-shade-plugin</artifactId>
        <version>3.2.2</version>
        <executions>
            <execution>
                <phase>package</phase>
                <goals>
                    <goal>shade</goal>
                </goals>
                <configuration>
                    
                    
                    <artifactSet>
                        <excludes>
                            <exclude>com.google.code.findbugs:jsr305</exclude>
                            <exclude>org.slf4j:*</exclude>
                            <exclude>log4j:*</exclude>
                        </excludes>
                    </artifactSet>
                    <filters>
                        <filter>
                            
                            <artifact>*:*</artifact>
                            <excludes>
                                <exclude>META-INF/*.SF</exclude>
                                <exclude>META-INF/*.DSA</exclude>
                                <exclude>META-INF/*.RSA</exclude>
                            </excludes>
                        </filter>
                    </filters>
                    <transformers>
                        <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
                            <mainClass>hk.com.easyview.lifecycle_calc.LifecycleCalcStartup</mainClass>
                        </transformer>
                        <transformer implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer" />
                        <transformer implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer">
                            <resource>META-INF/spring.handlers</resource>
                        </transformer>
                        <transformer implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer">
                            <resource>META-INF/spring.schemas</resource>
                        </transformer>
                    </transformers>
                </configuration>
            </execution>
        </executions>
    </plugin>

**问题点**：就是这行![\\mathrm\{\{\\color\{DarkRed\} <minimizeJar>true</minimizeJar>\}\}][mathrm_color_DarkRed_ _minimizeJar_true_minimizeJar]，注释掉就OK了！！！重新打包上传，启动成功！！！个人推测，应该是这个压缩配置，改变了包的一些文件结构或是部分文件，所以导致启动报错！

--------------------

# 3.总结 #

找这个问题花了半天时间，都有点懵逼了！问了身边的同事，最后还是自己冷静分析，查找差异之处，定位到了这个问题！

所以，解决问题时，还得冷静处理。。。

如果疑问，欢迎各位下方留言探讨！！！！感谢一键三连！！

[Link 1]: https://blog.csdn.net/yy339452689/article/details/109314083
[mathrm_color_DarkRed_ _minimizeJar_true_minimizeJar]: https://latex.codecogs.com/gif.latex?%5Cmathrm%7B%7B%5Ccolor%7BDarkRed%7D%20%3CminimizeJar%3Etrue%3C/minimizeJar%3E%7D%7D