1回答
我们有一个由不同团队管理的Flink集群。群集在多个作业之间共享。因此，在任何特定时间，任何任务管理器都有运行不同作业操作的槽。
这是否建议与其他作业共享prod中的集群？如果一个作业失败，它也会杀死运行另一个作业线程的任务管理器？如果我们没有其他的方法，并且必须使用共享集群，那么处理异常场景的最佳方法是什么，以便在任务管理器以致命错误自杀时不会杀死另一个作业？
浏览 2提问于2018-06-12得票数 2
回答已采纳
我有一个设置了3个节点的flink集群。在web界面中，我看到3个任务管理器、3个任务槽和3个可用任务槽。下面是我的和文件。Check log-files for details.python: can't open file '/data/tmp/flink/flink-dist-cache-9fc4a122-1f2
浏览 0提问于2017-07-21得票数 0
回答已采纳
1回答
Flink集群时，将收到以下错误消息：
VirtualBox:/media/sf_Python$ ./json_parser_flink.py程序的开始执行失败计划:空回溯(最近一次调用)：File“，第1行，文件"/tmp/flink_streaming_plan_fbe13c4c-6918-46d4:1510) at org.apache.flink.streaming.python.a
浏览 0提问于2019-03-06得票数 1
我的测试设置如下： 选项1:配置为使用--runner=PortableRunner 选项2:启动本地flink作业服务器， docker run --net=host apache/beam_flink1.10', '1.10',pipeline_options = PipelineOptions(pipeline_argstopic
浏览 17提问于2021-07-07得票数 0
我在纱线上运行flink作业，我们在命令行中使用"fink run“将作业提交给纱线，有一天我们在flink作业上出现了异常，因为我们没有启用flink重新启动策略，所以它只是失败了，但是最终我们从纱线应用程序列表中发现作业状态是”成功的“，我们期望它”失败“。Flink CLI日志：
06/12/2018 03:13:37 FlatMap (getTagStorageMapper.fl
浏览 1提问于2018-06-14得票数 1
回答已采纳
我想在Apache上使用Apache运行Python代码。apache站点在Apache上启动Python代码的命令如下：下面讨论了在Apache上使用Apache执行代码的不同方法。
浏览 6提问于2020-03-01得票数 0
().build()
t_env = BatchTableEnvironment.create(evnironment_settings = env_settings) 但是我发现其中一个样式只适用于flinkrun -py batch.py，其他一些样式可以作为python batch.py运行在本地。我的问题是executionEnvironment和BatchTableEnvironment/StreamTableEnvironment有什么区别，什么时候可以使用flink运行-py，什么时候可以通过安装了pyflink的<
浏览 107提问于2020-12-18得票数 0
当我登录到Flink仪表板时，在每个作业的右边，在标题Tasks下，有几个不同数字的彩色框。他们代表什么？我似乎在互联网上找不到这些信息！
浏览 0提问于2018-07-06得票数 1
回答已采纳
目前，我正在使用144个TaskSlots在4台机器的远程集群上运行Flink程序。在运行了大约30分钟之后，我收到了以下错误：
信息org.apache.flink.runtime.jobmanager.web.JobManagerInfoServlet -职务管理器信息服务器:未能为作业UncheckedPrintWriter.java:280)，org.eclipse.jetty.io.UncheckedPrintWriter.write(UncheckedPrintWriter.java:295)，org.apache.f
浏览 1提问于2016-01-08得票数 0
回答已采纳
1回答
我有一个在Flink 0.9中开发的作业，它使用图形模块(Gelly)。该作业在IDE (Eclipse)中成功运行，但在使用maven (mvn干净安装)将其导出到JAR后，它未能在本地flink实例上执行，并出现以下错误java.lang.NoClassDefFoundError: org/apache/flink/graph/GraphAlgorithm
浏览 4提问于2015-05-07得票数 5
回答已采纳
1回答
我在一台机器上启动flink (bin/ start -cluster.sh)，并通过flink web UI提交作业。如果作业有问题，比如接收器mysql表不存在或keyby字段错误，不仅这个作业失败，我不得不取消失败的任务，但在取消后，任务管理器似乎被“杀死”，它在flink web ui中消失。有没有容错的解决方案(taskmanager会被失败的作业杀死)？唯一的方法是在纱线上运行flink
浏览 19提问于2018-09-04得票数 0
1回答
我正在学习Flink，并且正在执行一些小程序。我看到有很多与Flink相关的进程。当我启动集群时，它会启动作业管理器的进程和任务管理器的进程，并执行它们的程序。当我启动应用程序时，它会启动一个新进程。在任务管理器的进程中有一个用于执行任务的插槽，但是新的进程做什么呢？
浏览 20提问于2019-11-28得票数 1
我正在使用Flink v1.4.0。...当我试图通过Flink UI提交相同的作业以在集群上安装的本地Flink版本上运行时，也会出现同样的问题。在这
浏览 0提问于2018-04-17得票数 2
回答已采纳
我有一个Flink作业，其中我正在读取文件夹中的文件，并将其转储到数据库中。每天都会有新文件进入该文件夹。我已经启用了检查点，以便如果由于任何原因Flink作业停止并且我需要重新启动，Flink作业不应该读取已经读取的文件。我在代码中添加了以下代码行，但当我重新启动作业时，Flink作业再次读取所有文件。
浏览 44提问于2019-01-23得票数 5
在flink中有两个作业在运行，如果其中一个失败了，我需要让整个flink应用程序失败吗？我该怎么做呢？假设并行度为1的作业由于某种异常而失败，如何使并行度为4的作业失败？ ?
浏览 5提问于2020-07-25得票数 0
回答已采纳
我使用Yarn来运行Flink作业。对于每个Flink作业，我都要创建一个检查点。
我提交一个在我的Yarn集群中运行的Flink作业。我有一个轮询作业，它检查一个作业是否在Yarn上失败并重新启动它。当作业再次提交时，Yarn为该Flink作业创建一个新的application_id。如何配置重新提交的Flink作业以使用重新启动的Fl
浏览 0提问于2018-05-22得票数 0
回答已采纳
当flink的内部作业失败时，如何使纱线上的flink应用程序终止或失败？无论有多少作业失败，应用程序仍在运行，因此无法立即发现问题。你有什么想法吗？
浏览 1提问于2018-03-22得票数 0
在Apache Flink (例如v1.8)中，作业管理器和作业主机之间有什么区别？作业管理器和作业主机有什么不同？
谢谢!
浏览 3提问于2019-06-27得票数 1
3回答
我正在flink群集内运行flink流作业。我需要模拟一个作业失败的场景。我在我的源代码中引入了一个损坏的事件。当该事件发生时，我看到抛出异常的作业和任务已经从检查点重新启动。根据文档，作业应在第一次尝试后失败。我需要模拟作业失败的场景。该怎么做呢？
浏览 38提问于2020-10-13得票数 0
回答已采纳
我正试图将Sentry附加到我们的Flink集群以跟踪作业执行。Sentry充当记录器，捕获消息并将其发送到中央服务器。默认情况下，它捕获所有级别警告或更高级别的消息。如果重新启动策略失败，执行环境中的execute()方法将抛出最后一个异常，我可以适当地记录该异常。但我还没有找到记录导致作业重新启动的异常的方法。Flink将它们记录为信息消息，但这使得它们很难从其他信息中过滤。
在Flink作业中处理不明确异常的适当方法是什么？
浏览 2提问于2018-05-01得票数 8
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
