在Flink v-1.4中，有一个rest api来获取所有已完成/已完成的作业： /joboverview/已完成 正如我所看到的，在v-1.6中没有这样的api，我如何才能只获得已完成/已完成的作业
浏览 22提问于2019-01-25得票数 0
3回答
我有一个Java应用程序午餐，一个flink作业来处理Kafka流。在flinkEnv.execute("flink job name")提交作业时，应用程序在这里挂起，因为作业将永远运行，以获取从kafka传入的流。
在这种情况下，如何从执行过程中返回作业id？我看到控制台里打印的是假名。只是想知道，如何得到flinkEnv.execute还没有回来的情况下<
浏览 3提问于2016-09-16得票数 0
在SCALA代码中使用Kafka/FLink命令行-“命令”Starting Flink Server
St
浏览 7提问于2017-10-09得票数 0
回答已采纳
，...)为了将Flink应用程序部署从会话模式更改为作业模式？此外，我们通过一个ansible角色在openshift上设置了flink集群，但不幸的是，它不是从ansible galaxy存储库中获取的，所以我不能引用任何已发布的设置。可能，大多数配置更改都必须在上面提到的配置flink文件之外的地方完成。我不明白的是，如何控制提交新
浏览 33提问于2019-09-06得票数 1
回答已采纳
我在纱线上运行flink作业，我们在命令行中使用"fink run“将作业提交给纱线，有一天我们在flink作业上出现了异常，因为我们没有启用flink重新启动策略，所以它只是失败了，但是最终我们从纱线应用程序列表中发现作业状态是”成功的“，我们期望它”失败“。Flink CLI日志：
06/12/2018 03:13:37 FlatMap (getTagStorageMapper.flatMap)(23
浏览 1提问于2018-06-14得票数 1
回答已采纳
谁能告诉我在运行Spark作业时如何确定缓存的最大内存量？我需要它来显示我的算法在不同输入大小下的性能(内存利用率)。
提前感谢
浏览 0提问于2015-12-11得票数 0
我有一个usecase，其中我需要使用有界的RocksDB源为Flink应用程序(包括RocksDB状态和广播状态)种子，然后在种子播种完成后读取其他无界/有界的S3源。我试着用两个步骤来实现这一点：
对于步骤1: Flin
浏览 2提问于2022-11-11得票数 1
当我登录到Flink仪表板时，在每个作业的右边，在标题Tasks下，有几个不同数字的彩色框。他们代表什么？我似乎在互联网上找不到这些信息！
浏览 0提问于2018-07-06得票数 1
回答已采纳
我试图为Flink实现一个Rest客户端，通过Restful服务发送作业。我也想把Flink和Kubernetes结合起来。根据Flink文档，我决定使用“应用程序模式”作为部署模式。我已经实现了一个作业，并将其打包为jar。我已经在独立的Flink上测试过了。但是我的目标是通过Flink的Rest在应用程序模式下继续使用Kubernetes并部署我的应用程序。对
浏览 10提问于2022-04-04得票数 0
正如我们所知道的，spring批处理作业在运行过程中会在下面的状态下运行，我希望实时听到这些状态变化，并使用当前状态对rest进行post调用。对于Ex: 1.当作业"X“启动时，它的初始状态是”启动“，我想要听此状态更改并调用rest 2。当作业"X”状态更改为“已启动”时，我想听此状态更改并调用rest .
已完成
浏览 0提问于2019-03-22得票数 0
根据我的理解，TaskManager恢复是由JobManager辅助的(这是预期的)，而JobManager恢复是通过Zookeeper完成的。我想知道是否有一种方法可以在没有zookeeper的情况下恢复作业管理器？当所有作业管理器都宕机时，flink是否能够恢复？当我重新启动作业管理器时，我
浏览 16提问于2018-09-07得票数 1
回答已采纳
1回答
见守则：from org.apache.flink.api.common.functionsenv.create_python_source(Json_reader()) \ .output()当我构建作业并将其移动到已</em
浏览 0提问于2019-03-06得票数 1
如何在酱汁中标记测试通过/失败？我用PHPunit编写了测试用例。现在所有的测试用例都被标记为“完成”。
浏览 2提问于2014-10-29得票数 1
1回答
我正在尝试运行https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/projectsetup/java_api_quickstart.html中描述的演示应用程序。我使用给定的脚本生成了项目： curl https://flink.apache.org/q/quickstart.sh | bas
浏览 17提问于2020-03-31得票数 0
2回答
我在Intellij中运行Apache Flink迷你集群。正在尝试设置流联接，其中一个流来自kinesis源，另一个流来自jdbc。DataStream<Row> dsRow = tableEnv.toAppendStream(table, Row.class); 我在堆栈跟踪中收到以下信息消息： INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator
浏览 39提问于2020-12-10得票数 0
我有一个运行多个配置单元脚本的unix shell脚本。我已经为配置单元脚本中的每个配置单元查询指定了作业名称。我需要的是，在shell脚本的末尾，我希望根据作业名称检索用于配置单元查询的资源(在内存、容器方面)，这些资源来自具有appstatus为“FINISHED”的YARN日志/应用程序。
我该怎么做呢？
浏览 11提问于2017-08-13得票数 0
回答已采纳
1回答
我是新的谷歌教室API，并想澄清是否可以访问工作从“指定的”选项卡，如果可能的话，所有的标签在下面的图像。我用的是Javascript。谢谢!
(我需要10个声誉来发布照片。-。这是链接)
浏览 5提问于2019-06-14得票数 0
回答已采纳
当我们在作为SQL Server数据库表的源的Flink SQL CLI中选择任何表时，为什么Flink作业在从数据库表中获取所有记录后“完成”？有没有可能让它“运行”，这样它就可以从数据库表中获取最新的数据？
浏览 4提问于2020-12-25得票数 1
我想了解LocalExecutionEnvironment的局限性，以及它是否可以在生产中运行？ 感谢任何帮助/洞察力。谢谢
浏览 26提问于2019-12-24得票数 1
回答已采纳
1回答
我使用Apache Flink将来自给定的Kafka主题集的更新传播到Elasticsearch集群中。我面临的问题是，有时Elasticsearch集群会进化，而我必须通过(1)修改映射，当我不得不将Flink作业指向新的别名/索引时，(2)复制到data...and时，就会有大量的更新到旧的索引。所以我想知道什么是最好的方法来解决这个问题。我可以休息，但如果可能的话，我想避免这样做。我试图使Fl
浏览 5提问于2022-06-21得票数 0
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
