部署新版本的Flink应用程序失败
- 环境
- Flink1.7.1
- Kafka1.0.1
当我用新版本的代码更改应用程序并进行部署时，就会出现应用程序执行失败的问题
如果我部署相同的组。id更改应用程序代码后，是否会与以前的状态检查点信息发生冲突？
共有1个答案
是的，如果您试图对Flink应用程序进行有状态升级，有一些事情可能会导致它失败。
有状态运算符的UID用于查找每个运算符的状态。如果尚未设置UID，则如果作业的拓扑结构已更改，状态还原将失败，因为Flink无法找到状态。有关详细信息，请参阅有关分配操作员ID的文档。
如果删除了有状态运算符，则应在指定allowNonRestoredState的同时运行新作业。
如果您修改了数据类型，则在尝试对检查点或保存点中的状态进行反序列化时作业可能会失败。Flink 1.7不支持自动模式演变或状态迁移。在Flink的最新版本中，如果您坚持使用POJO或Avro，这将自动处理。否则您需要自定义序列化程序。
如果这不能帮助您找出问题所在，请共享显示特定异常的日志中的信息。
-
我试图使用argocd部署一个spring应用程序的Kubernetes集群，但我在其中遇到了错误。我首先使用GitLab ci管道构建docker映像，然后使用argocd进行连续部署。错误是： 我没有得到任何解决这个问题的方法，如果有人对此有任何想法，请回复。 这是我的配置文件： 这是我的申请。配置所有内容的yml文件。 谢谢
-
情况如下： 我使用maven和cargo plugin将web应用程序自动部署到不同的环境中，使用Hudson运行/调度作业来完成这项工作。我使用tomcat作为目标应用程序容器。 但是我想找到最好的方法来备份部署的Web应用程序到某个网络/FTP位置，在maven/货物部署最新版本之前。我一直在寻找一些有助于做类似事情的maven插件，但似乎像这样的任务超出了maven的范围。此外，我正在寻找一
-
我运行< code>heroku open时出现应用程序错误。我查了日志，这是: 2016-06-19T05:22:44.640391 00:00 heroku[路由器]：at=错误代码=H10 desc=“应用程序崩溃”方法=获取路径=“/”主机=drawparty-.herokuapp。com request_id=6712804b-95f9-49ce-92a5-7f45df7bb79e fw
-
我使用Netbeans创建了带有ejb模块和war模块的Java企业应用程序。我对战争模块做了一些改动，一切正常。但现在我正在尝试调用ejb模块中定义的远程ejb。我已经学习了本教程https://netbeans.org/kb/docs/javaee/entappclient.html。现在，当我尝试在应用服务器(JBossAS7)中部署ear文件时，我得到以下错误： {“JBAS014653:
-
我的应用程序在play store上已经有一段时间了，而且还起作用了。昨天我发布了一个更新，发现里面有一个bug，我今天就想修复它。在将我的alpha apk上载到publisher页面并带有新版本和versioncode（这样我就可以测试购买了）之后，in app购买在这个新版本中就不起作用了。我没有更改任何与应用程序计费相关的代码。我正在使用iab库的v3。 我得到它的时候，购买意图被调用。u
-
尝试在Heroku云中部署Spring Boot应用程序，但编译java应用程序时出现错误，但在我的本地计算机中运行良好。