我已经编写了使用数据集和数据流api的flink作业。我已经从相同的main()方法启动了两个程序,但是现在当我将作业提交给flink Dashboard时。只有数据集api程序正在运行,仪表板说作业完成,流没有被触发,flink仪表板也没有显示任何关于数据流执行的信息。但是当我从eclipse运行时,数据集和datastream api程序都在运行。有没有其他方法将作业提交给flink作业管理器来完成这两项工作?。
解决方案是将这两个程序分成不同的类,例如MyStreamingProgram和MyBatchProgram,每个类都有一个main方法。然后,将每个计划分别提交给Flink,以便创建两个独立的工作岗位。
您提到您观察到行为中的一些变化,具体取决于作业的提交方式。在幕后,Flink使用各种策略来执行main
方法以获取程序计划。不支持在main
的单个执行中生成多个计划(AFAIK)。
除了使用web仪表板,还可以使用命令行界面和REST api向Flink提交作业。
然而,听起来您可能正在尝试一个同时使用DataSet和DataStream API的Flink作业。这行不通。
我试图理解Apache Flink仪表板显示的“接收/发送的字节”是什么意思。在某些情况下,CSV文件托管在HDFS服务器上,我正在将结果写入机器上本地的TXT文件中。Flink也在我的机器上本地运行。考虑到这一点,“发送的字节”似乎是指“从HDFS服务器发送到我的机器的字节”,“接收的字节”似乎是指“从我的机器发送到HDFS服务器的字节”。这是正确的解释吗? 时间线显示的重叠任务也让我有点困惑。
问题内容: 我有一个ID为ID的表单,该表单具有以下div,其中包含一个Submit按钮: 单击后,将调用该函数。该函数将上述div的innerHTML更改为“ processing …”(因此,提交按钮现在消失了)。 上面的代码有效,但是现在的问题是我无法提交表单!我试着把它放在函数中: 但这是行不通的。 我该如何提交表格? 问题答案: 将表单的属性设置为,代码即可正常工作。
问题内容: 我正在尝试使用phantomJS(真棒的工具!)为具有登录凭据的页面提交表单,然后将目标页面的内容输出到stdout。我可以使用幻像访问该表单并成功设置其值,但是我不太确定提交表单并输出后续页面内容的正确语法。到目前为止,我有: 问题答案: 我想到了。基本上,这是一个异步问题。您不能只是提交并期望立即呈现下一页。您必须等到触发下一页的onLoad事件。我的代码如下:
在ResourceManager节点上启动flink作业(查找配置文件) 从ResourceManager下载配置文件到本地。 我想,这两种方式都不太好。如何将作业提交到远程纱线集群。有没有合适的办法?
问题内容: 目前,我的AJAX正在这样工作: index.php 一个.php ajax.js 上面的代码运行完美。当我单击链接 “ One”时, 将执行 one.php 并将字符串 “ One” 加载到 工作区DIV中 。 现在,我想使用AJAX提交表单。例如,我在 index.php中 有一个这样的表单。 当我提交表单时, one.php 应该在工作区DIV中打印文本框值。 如何编码js以使用
null 申请后: 仪表板可以通过库贝代理访问。所以我把service命名为Nodeport: 然后我尝试通过https Nodeport访问仪表板。它失败了。当我试图访问192.168.100.31或192.168.100.32时,比如: