2回答
我已经为在Intellij IDEA中运行的应用程序设置了Flink UI。我想获得一些流指标，如-调度延迟和处理时间。但是，我在UI中找不到anywhere。目前，该作业的Flink UI如下所示： ?
浏览 25提问于2020-01-21得票数 0
回答已采纳
1回答
我想创建一个带有一些逻辑(Scala)的Flink Job，并在文档中找到了几种启动Flink的方法。例如，独立模式： ./bin/flink run ./examples/streaming/TopSpeedWindowing.jar 它可能是从Intellij Idea启动和调试Flink作业，就像使用主类启动和调试简单的Spark job一样吗？def main(args: Ar
浏览 42提问于2021-01-30得票数 0
我对Flink世界很陌生，我想通过在SensorTimeAssigner和AvegrageTemperatureWindow函数类中放置be断点来逐行调试Flink作业。跟随本文io.github.streamingwithflink.chapter1.AverageSensorReadings.java
浏览 8提问于2022-01-26得票数 0
回答已采纳
我有一个Flink流程序，从卡夫卡的主题读取数据。在程序中，auto.offset.reset被设置为“最小”。当在IDE/Intellij-IDEA中测试时，程序总是可以从主题的开头读取数据。然后我建立了一个flink/kafka集群，并将一些数据生成到kafka主题中。当我第一次运行流式作业时，它可以从主题的开头读取数据。但在此之后，我停止了流作业，并再次运行它，它将不会从主题的开头读取数据。如何才能使程序始终
浏览 5提问于2015-12-15得票数 0
3回答
我试图从oreilly书“用Apache进行流处理”和flink项目中运行第一个示例。每个错误都是不同的
例如，在书中，flink项目的NoClassDefFound错误示例给出了java.net.ConnectException:连接拒绝(连接拒绝)，但是确实创建了一个flink作业，我将jar放在运行命令的同一个目录中。https://github.com/streaming-with-flink/examples-scala
浏览 7提问于2020-04-05得票数 1
回答已采纳
正如在中所描述的，我无法成功地运行“使用Apache进行流处理，包括预编译的jar”一书中的任何代码。使用IDE并不是我的实践，但我想我应该尝试使用IntelliJ，因为第3章“在IDE中运行和调试Flink应用程序”描述了如何为本书的代码专门这样做。以下是复制的步骤启动IntelliJ
浏览 2提问于2020-04-15得票数 2
回答已采纳
我可以在IntelliJ IDEA中调试nifi吗？因为我只在http://nifi.apache.org/quickstart.html中看到了如何构建nifi项目并使用外壳命令运行，没有关于如何在IDEA中运行或调试的信息，例如IntelliJ IDEA
浏览 28提问于2019-05-15得票数 2
回答已采纳
我从github克隆了flink代码，并用Intellij Idea打开它，我没有在IJ或代码中做任何配置(我已经安装了IJ scala插件和scala sdk)，我直接在Intellij Idea中运行以下两个示例我能够成功地运行批处理模式字数统计示例(代码是类org.apache.flink.examples.scala.wordcount.WordCount in flink-examples-batch_但是当我尝试运行<em
浏览 2提问于2019-01-12得票数 1
我想通过以下代码在本地使用Flink-API读取CSV文件：List<Tuple2<String, Double>> csv= env.readCsvFile:408)at org.apache.flink.client.LocalExecutor.executePlan(LocalExec
浏览 22提问于2017-01-11得票数 0
我们可以看到，在将Flink度量暴露于外部系统(如Prometheus )时，Flink使用Pushgateway而不是Prometheus通常的拉模型进行一般度量集合。", jobName, e);}
然而，从Prometheus下面的官方文档中可以看出，"Prometheus直接或通过中间推送网关为短寿命作业从工具作业中收集指标“，显然Flink流作业不是短暂的工作，那么为什么
浏览 2提问于2018-08-19得票数 0
回答已采纳
2回答
有没有任何方法来支持一个以上的流媒体源，如卡夫卡和twitter在单一的flink工作？是否有任何工作，around.Can，我们一次处理多个流源，在单个flink作业中？我目前工作在星火流，这是限制在那里。人们期待着人们的回应。
浏览 5提问于2016-11-06得票数 5
回答已采纳
1回答
我使用的是Flink 1.12。我想读取csv，并根据处理时间进行翻滚窗口分组。代码如下，但是查询sql_tubmle_window没有输出，我想知道问题出在哪里 import org.apache.flink.streaming.api.scala._import org.apache.flink.types.Row
def ma
浏览 5提问于2021-05-02得票数 0
回答已采纳
当我使用Intellij运行应用程序时，它总是帮助我添加许多参数或VM选项，例如： /usr/lib/jvm/java-11-oracle/bin/java -Dspring.liveBeansView.mbeanDomain -javaagent:some/idea_rt.jar=40157:/home/vincent&
浏览 25提问于2019-01-03得票数 1
1回答
我已经在批处理中使用了apache一段时间，但现在我们希望将这个批处理作业转换为流作业。我遇到的问题是如何运行端到端的测试。如何在批处理作业中工作
我们希望对流作业做一些类似的事情，除非流作业没有真正完成。所以：
浏览 1提问于2018-07-09得票数 4
回答已采纳
如何在IntelliJ-Idea？中调试时跳过JRE -- Java代码在Eclipse中，调试过滤器运行良好。但是，和IntelliJ在一起我正在挣扎。有什么帮助吗？
浏览 4提问于2015-01-12得票数 1
有时我需要在IntelliJ调试器中运行它，但是我们经常意外地破坏“本地调试流”。没有管道可以检查IntelliJ运行配置和一些比较复杂的云模拟代理和模拟服务器是否与代码库同步。我想编写一个脚本来帮助我检查本地调试流是否有效。脚本应该执行以下操作：
构建项目，启动“模拟云”，在本地启动服务，使用IntelliJ ，一个邮递员集合，针对本地运行的服务。我需要步骤3(可能还有步骤1)的帮助:如何通过命令行启动IntelliJ</e
浏览 6提问于2022-04-26得票数 1
httpPort = 8080 servletContainer = 'jetty9'当我以“gretty -> appStartDebug”的形式调试应用程序时这是调试gradle应用程序的正确方法吗？
浏览 6提问于2017-11-27得票数 0
回答已采纳
如何在AngularJS想法中运行我的IntelliJ应用程序？我使用IntelliJ IDEA的最后一个版本，并将AngularJS支持与IntelliJ IDEA AngularJS插件一起安装。我想知道，我不能定义一些服务器运行/调试配置(比如Tomcat)来运行我的应用程序。编辑:或者还有其他方法来部署应用程序？我找不到任何合适的运行/调试配置来在本地部署我的项目。
浏览 5提问于2016-03-10得票数 1
回答已采纳
我目前在mac os el capitan上运行最新的IntelliJ。ClassLoader.java:357)at java.lang.Class.forName(Class.java:264)
at com.intellij.rt.execution.application.AppMain.main
浏览 8提问于2017-01-29得票数 1
回答已采纳
我是IntelliJ的新手，我创建了一个新的空项目(Google)，并将字节码级别更改为7，但我在部署中遇到了这个错误：
java.lang.IllegalArgumentException: Class
浏览 2提问于2017-01-16得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
