1回答
我目前正在开发一个流处理应用程序，其中一个功能是获取在提交作业的时区时间内发生的事件，提交作业的时间+T。谢谢。
浏览 14提问于2020-05-24得票数 0
1回答
我使用以下命令在本机K8s上使用会话模式创建了一个Flink集群：基于。
我能够向集群提交作业并查看Flink UI。但是，我注意到，Flink只在作业提交时创建一个任务管理器结荚，并在作业完成后立即删除它。
浏览 10提问于2022-08-30得票数 1
回答已采纳
我正在用最新版本的flink 1.5在kubernetes上试用flink作业。我的问题是如何在上面的flink集群上运行一个示例应用程序。提供了如何使用flink应用程序构建docker镜像并将该应
浏览 0提问于2018-06-22得票数 1
假设我有一个Flink应用程序来过滤、转换和处理流。有关数据流，请参阅下面的图像。用例的原因：为了有效地使用Java在任何给定的时间存储更多的事件，需要转换。在单个TaskManager上完成这三项操作也有一个缺点，即存储摄入的事件，而在这些事件中，几乎不需要80
浏览 3提问于2020-08-02得票数 0
回答已采纳
3回答
我有一个Java应用程序午餐，一个flink作业来处理Kafka流。在flinkEnv.execute("flink job name")提交作业时，应用程序在这里挂起，因为作业将永远运行，以获取从kafka传入的流。
在这种情况下，如何从执行过程中返回作业id？只是想知道，如何得到flinkEnv.execute还没有回来的情况下的工作身份。
浏览 3提问于2016-09-16得票数 0
1回答
我正在尝试从python SDK运行一个基本的字数束管道，并在AWS EMR上使用flink yarn会话。我同时使用了flink runner和便携runner，得到了下面列出的两个不同的错误。这两种类型的运行器的作业都会显示在flink UI中，并在我的笔记本电脑上使用本地flink会话成功运行。PortableRunner，作业以BeamApp-root-0617202248
浏览 17提问于2020-06-18得票数 2
回答已采纳
1回答
我试图使用Flink REST通过管道自动化Flink作业提交过程。要调用任何Flink Rest端点，我们应该了解接口IP。对于我的POC，在CLI上运行flink-session命令之后，我得到了IP，但是从代码中获得它的方法是什么呢？
requests.post('
浏览 9提问于2022-10-12得票数 0
我们的团队在我们的K8S集群中设置了一个Flink会话集群。我们选择Flink会话集群而不是工作集群，因为我们有许多不同的Flink作业，因此我们希望将Flink的开发和部署与我们的作业分离开来。我们的Flink设置包含：
我们在单独的存储库中开发作业，并在代码合
浏览 0提问于2020-02-27得票数 1
回答已采纳
当我启动一个flink独立集群时，它会在conf/log4j.properties文件中提到的文件中记录守护进程日志，当我在该集群中提交flink作业时，它会使用相同的属性文件来记录应用程序日志并在任务管理器上写入相同的日志文件我希望为在flink独立集群中提交的每个应用程序都有单独的日志文件。有什么办法可以做到这一点吗？
浏览 1提问于2016-11-08得票数 1
1回答
EKS上的Flink集群
、、、、
现在我试图在kubernetes主持这项工作，并希望在AWS中使用EKS。
我已经阅读了关于如何设置flink集群的官方flink文档。我尝试使用minikube在本地设置它，并启动了会话集群，并提交了工作正常的作业。我的问题是:1)在两个选项中，作业集群和会话集群，因为作业是流作业，应该保持对文件系统的监视，当新文件传入时，它应该流到目的地，在这种情况下，我可以使用作业<
浏览 9提问于2020-01-08得票数 0
回答已采纳
我使用Yarn来运行Flink作业。对于每个Flink作业，我都要创建一个检查点。
我提交一个在我的Yarn集群中运行的Flink作业。我有一个轮询作业，它检查一个作业是否在Yarn上失败并重新启动它。当作业再次提交时，Yarn为该Flink作业创建一个新的application_id。如何配置重新提交
浏览 0提问于2018-05-22得票数 0
回答已采纳
我试图为Flink实现一个Rest客户端，通过Restful服务发送作业。我也想把Flink和Kubernetes结合起来。根据Flink文档，我决定使用“应用程序模式”作为部署模式。我已经实现了一个作业，并将其打包为jar。我已经在独立的Flink上测试过了。但是我的目标是通过Flink的Rest在应用程序模式下继续使用Kubernetes并部署我的应用程序。对于应用程序
浏览 10提问于2022-04-04得票数 0
2回答
我已经将包含应用程序代码的胖jar上载到Flink集群中所有节点的/lib文件夹中。我正在尝试从一个单独的java应用程序启动Flink作业，但是找不到一个很好的方法。但是，这只允许您运行通过作业上载函数提交的作业。
我在flink客户端模块中看到了ClusterClient.java，但没有看到如何使用它的任何示例。如果有人通过java代码成功地提交了
浏览 12提问于2020-01-28得票数 4
在配置文件(job-manager- config /flink-conf.yaml，task-manager-config/flink-conf.yaml，job-manager-config/zoo.cfg，...)为了将Flink应用程序部署从会话模式更改为作业模式？此外，我们通过一个ansible角色在openshift上设置了flink集群，但不幸的是，它不是从ansible galaxy存储库中获取的，所以我不
浏览 33提问于2019-09-06得票数 1
回答已采纳
我是Kubernetes的新手，并试图了解Flink在它们上的部署有何不同。如果对内部结构有任何了解，这将是非常有帮助的。
浏览 53提问于2020-08-06得票数 3
回答已采纳
在使用命令行将作业提交给Flink时，是否有任何方法来测量Apache中的作业执行时间？
PS。我希望flink API给我时间，而不是通过记录开始和结束时间来自己用bash度量它。
浏览 3提问于2015-12-12得票数 7
回答已采纳
我正在尝试使用Flink客户端向Kubernetes集群(会话模式)提交一个Flink作业。问题是，当我尝试使用Stringvalue=System.getenv(name)读取java代码中的环境变量时，它返回null。那么，当使用Flink</em
浏览 0提问于2021-04-29得票数 0
我刚刚将Flink从版本1.10升级到1.11。在1.11中，Flink提供了新功能，用户可以在Kubernetes上以应用程序模式部署作业。https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deployment/kubernetes.html#deploy-session-cluster在V1.10中<
浏览 74提问于2020-09-02得票数 1
回答已采纳
1回答
我有来自Kafka的实时数据，我想使用Flink进行一些转换。
Flink应用程序群集是运行单个作业的专用群集。在这种情况下，您可以将作业部署到集群中，这样就不需要额外的作业提交了。作业工件包
浏览 5提问于2022-01-08得票数 0
回答已采纳
在SCALA代码中使用Kafka/FLink命令行-“命令”Starting Flink Se
浏览 7提问于2017-10-09得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云直播
实时音视频
腾讯云开发者
