我是Apache Flink的初学者，找不到任何关于扩展Flink核心的信息。我想从简单的开始:构建一个测试类。我应该将那个类保存为flink中的某个地方的jar-file吗？
浏览 0提问于2015-11-26得票数 1
我使用Maven在CentOS服务器中管理我的自定义Flink应用程序。我是Java的初学者。要构建一个空项目，我只需遵循，这意味着我执行了以下命令： -DarchetypeGroupId=org.apache.flink \
-DarchetypeArtifactId=flink-quicks
浏览 8提问于2020-05-27得票数 0
回答已采纳
我的直觉可能是正确的使用包装和/或分类器。为了为构建文件找到正确的导入标记，我建议查看.cache/bazel/bazel_user/.../external/maven/BUILD file我想使用Bazel构建工具测试我自己的异步flink流操作符RichAsyncFunction。我试着遵循提供的答案，但是我很难理解bazel语法，我问自己是否可以用bazel使用这些
浏览 0提问于2020-05-09得票数 1
我想从这个docs - operations playground开始使用flink playground (flink 13) docker-compose link进行docker-compose:3.6-jdk-8-slim 清单列表条目中没有与linux/arm64/v8匹配的清单 然后我尝试从--platform=linux/amd64 maven:3.8-jdk-8-slim添加到Dockerfile作为构建器，但有一个例外-
浏览 374提问于2021-09-27得票数 0
回答已采纳
我目前的尝试是：
每次更新到最新源代码时，都要重新构建Scala2.11的Flink。拥有正确的maven设置，以便在Eclipse中构建项目时，您的项目依赖关系不会被Flink</
浏览 1提问于2015-09-15得票数 1
回答已采纳
我正在使用Apache开发一个推荐系统。当我在IntelliJ中测试它时，这个实现正在运行，但是现在我想在集群上运行它。java.lang.NoClassDefFoundError: org/apache/flink/ml/common/flink ml$
正如我们所看到的，在我的代码中使用的类FlinkMLTools我用mvn clean install用Maven 3.3.3构建了这个jar，我使用</
浏览 1提问于2015-07-15得票数 4
回答已采纳
我试图使用以下方法读取该文件：DataSetenv.readTextFile("file:///pathtofile/myfile.txt");java.lang.NoSuchMethodError: org.apache.flink.api.common.io.DelimitedInputFormat: method
浏览 14提问于2017-10-24得票数 2
回答已采纳
3回答
我使用了最新的flink版本(1.10.0)和sbt(1.3.7)。在使用流sql查询上载作业时，我有此异常：
assemblyMergeStrategy in
浏览 3提问于2020-02-27得票数 0
1回答
我需要使用Bazel下载外部依赖jar文件。在何处配置以下载外部jar文件。我试图在构建文件和工作区文件中添加jar文件，但不起作用。工作空间文件maven_jar(name=&quo
浏览 2提问于2017-04-07得票数 0
我有一个流表API查询，并希望使用Table方法将结果.csv写入.csv文件。at org.apache.flink.api.table.FlinkPlannerImpl.rel(FlinkPlannerImpl.scala:102)
at org.apache.flink.api.table.BatchTableEnvironm
浏览 0提问于2016-12-20得票数 0
回答已采纳
我正在使用flink+ElasticSearch 5接收器，使用x-pack身份验证。所以我修复了它，覆盖了ES Sink函数。我现在的问题是，当我尝试在flink上运行作业(使用jar)时，我得到了这个错误。(FunctionUtils.java:36) at org.apache.<em
浏览 6提问于2017-03-23得票数 0
2回答
您好，我正在编写flink介绍，但我无法正确导入 import org.apache.flink.streaming.api.datastream.DataStream;import org.apache.flink.walkthrough.common.sink.AlertSink;
import org.apache.flink.walkthro
浏览 139提问于2020-08-31得票数 1
回答已采纳
1回答
我正在尝试构建一个apache作业，它必须通过HDFS访问文件。我正在使用Maven阴影插件来构建我的job.jar。Flink集群没有Hadoop jars，所以我必须将它们全部添加到作业本身。在本地，我必须在IDE设置中添加选项“向类路径添加”提供的范围“添加依赖项，以使其工作，但我不知道如何使用maven。flink-java</artifactId>
<version>
浏览 1提问于2022-01-23得票数 0
1回答
我在使用Maven时遇到了问题。我有一个Apache项目，希望在我的服务器上运行它。构建完成后，我查看了Jar文件。pom文件中的依赖项-部分如下所示： <dependency></dependencies>
当我在位于的存储库中看到包组织时，我认为可以将以下行添加到flink</em
浏览 0提问于2015-07-27得票数 4
回答已采纳
我正在用最新版本的flink 1.5在kubernetes上试用flink作业。我的问题是如何在上面的flink集群上运行一个示例应用程序。提供了如何使用flink应用程序构建docker镜像并将该应用程序提交给fli
浏览 0提问于2018-06-22得票数 1
1回答
他们都是大级别的用户，并问我是否有任何缺点或好处切换到使用gradle，而不是在未来的flink项目使用maven。现在我知道有很多比较maven和gradle的文章，但我的意思是专门针对apache。有两个git集线器repos，我发现乍一看，它们看起来像是在flink项目上实现gradle，但仅此而已。如果你能说出你在flink的经历，那也是有益的。( 1.)是否有“如果flink项目试图切换到gradle、x、y和z无法工作
浏览 1提问于2017-05-09得票数 2
回答已采纳
为了熟悉，我已经克隆了，并遵循了从构建和部署的说明。但是，在构建并导入到Eclipse IDE之后，项目中会出现错误。在Flink Training Exercises项目中，我在pom Plugin execution not covered by lifecycle configuration: net.alchim31.maven:scala-maven-plugin:3.1.4:testCompile中发现了错误。项目flink-quickstart-java中
浏览 40提问于2018-05-30得票数 0
回答已采纳
2回答
实际情况
如果您想使用Kinesis连接器，您不能像其他连接器那样使用ASL许可证，而且它们也不会将工件部署到Flink版本上的Maven中央存储库，因此您需要自己构建</
浏览 1提问于2018-12-27得票数 4
1回答
我有一个在Flink 0.9中开发的作业，它使用图形模块(Gelly)。该作业在IDE (Eclipse)中成功运行，但在使用maven (mvn干净安装)将其导出到JAR后，它未能在本地flink实例上执行，并出现以下错误java.lang.NoClassDefFoundError: org/apache/flink/graph/GraphA
浏览 4提问于2015-05-07得票数 5
回答已采纳
我对java和maven很陌生。我已经构建了一个执行flink作业的应用程序。我已经创建了一个基本的坞映像，但是我不知道如何像在终端中运行应用程序那样进行扩展/运行。我目前在终端中运行应用程序如下：
mvn package exec:java `-D exec.args="--runner=FlinkRunner --flinkMaster=localhost:8081\target\maven_benchmar
浏览 3提问于2020-05-27得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
