我最近无法将任何jars上传到我的Flink集群，该集群在AWS EMR上的YARN下运行。有一个长时间运行的流媒体应用程序已经运行了26天。似乎临时目录已经被删除了，但我真的不认为我删除了它。在jobmanager.log中： 2019-02-12 22:02:05,156 WARN org.apache.flink.runtime.webmonitor.handlers.JarListHandler- Jar upload dir /tmp/flink<
浏览 40提问于2019-02-13得票数 0
回答已采纳
我得到的错误信息是$ cd flink-0.9.0
$ .Diagnostics: File file:/home/hadoop/.flink/application_1439466798234_0008/flink-conf.yaml does not existjava.io.FileNotFoundException: File file:/home/hadoop&#
浏览 4提问于2015-08-13得票数 8
回答已采纳
username STRING,) WITH ( 'path'='s3://d11-data-lake-load/flink/events_data/test_flink/test-parquet',);
[INFO] Table has been
浏览 7提问于2021-05-12得票数 0
如果用户正在上传一个大文件并取消上传，该文件将保留在我的临时目录中。
是否有办法捕获已取消的上载(在文件完全上载之前重置连接)，以便清理这些文件？我能想到的唯一替代方法是cron作业，它查看temp目录并删除在一段合理的时间内未更新的文件。
浏览 2提问于2011-12-30得票数 2
回答已采纳
Apache Flink 1.10.2的REST API中存在CVE-2020-17518漏洞。现在我想关闭REST API服务，我应该如何设置配置文件？
浏览 2提问于2021-01-14得票数 0
1回答
将数据流从flink传输到S3
、、、、
我在amazon EMR上使用Flink，并希望将我的流水线结果流式传输到s3存储桶中。我使用的是Flink版本=> 1.11.2 这是代码片段，展示了代码现在的样子，变量： val outputPath = new Path("s3://test/flinkStreamTest/failureLogs:528) at org.apache
浏览 573提问于2021-05-11得票数 1
2回答
我想将NewRelic工具添加到flink作业中。我看不出在哪里可以向bin/flink run <job>命令传递额外的类路径/其他参数。NewRelic java代理希望将-javaagent:<path to jar>添加到执行路径中。传递配置文件路径也是可取的。编辑：env.java.opts: "-javaagent:/opt/newrelic
浏览 1提问于2015-11-22得票数 7
--versionHadoop配置目录已添加到flink-conf.yaml
# cat flink/config/flink-conf.yaml的aws-java-sdk-1.7.4.jar、hadoop-aws-2.7.4.jar、httpclient-4.2.5.jar、httpcore-4.2.5.jar从添加到flink</e
浏览 16提问于2017-08-13得票数 2
回答已采纳
我正在kubernetes (会话集群)上部署一个flink集群，我想知道是否有任何配置(在flink-conf.yaml上)可以将外部jars加载到集群中。据我所知，flink将加载lib/ folder下的所有jar，但假设我想上传用于指标的jar，并且我不想手动将其放入lib文件夹(因为每次部署都会将其删除)，并且我不希望将lib/ folder挂载。我想要的解决方案是创建一个/mnt/external-jars库(这将是一个挂载)，
浏览 148提问于2020-03-14得票数 0
在运行Flink JobManager和TaskManagers专用于某个特定作业的设置时，可以将JAR文件直接放到/lib文件夹中，以确保它们是类路径的一部分，而不是加载的动态类加载。at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:235) ~[iot-mirror-device.jar(StreamTask.java:231) ~[iot-mirror-device.jar
浏览 5提问于2018-03-28得票数 3
我正在使用flink和kafka，我得到了这个错误。-1.1.jar,curator-test-3.2.0.jar,disruptor-2.10.1.jar,flink-annotations-1.0.3.jar,flink-clients_2.10-1.0.3.jar,flink-clients_2.10-1.0.3-tests.jar,flink-core-1.0.3.jar,
浏览 2提问于2016-06-30得票数 4
python脚本相当简单，我只是尝试使用现有主题中的内容，并将所有内容发送到标准输出(或日志目录中的*.out文件，默认情况下，输出方法将在该文件中发出数据)。flink-1.6.1/lib'] for jar in glob.glob(os.path.join(directory,'*.jar文件，即flink-connector-kafka-0.9_2.11-1.6.1.jar、
浏览 0提问于2018-10-10得票数 4
检测到jar Ant API版本1.3结果:1初始化:deps- JavaFX :更新属性文件: D:\softphone\build \build-Clean.properties删除目录D：\softphone\build clean: deps-jar：更新属性文件:d：\softphone\build\build-jar.properties
已创建目录: D:\softp
浏览 1提问于2017-02-22得票数 0
在启动应用程序以使其正常工作之前，我需要将一些hadoop相关目录导出到类路径中(我不能跳过这一步)，我得到了以下错误。第二个是位于目录中的jar，其中包含来自hortonworks的所有hadoop依赖项，我需要将这些依赖项导出到类路径以使应用程序工作为(jsr311-api-1.1.1.jar)。(javax.ws.rs.jar)而不删除这个jar，因为它是我的大数据集群安装的一部分，我不能在类路径中使用这些jar。
有什么想法吗？:fli
浏览 7提问于2019-09-20得票数 1
回答已采纳
但是maven没有找到flink JDBC包。>flink-connector-jdbc_2.11</artifactId></dependency> System.out.println(e); }但是在使用mvn clean
浏览 7提问于2021-06-18得票数 0
回答已采纳
我看到上一个版本位于一个名为stage的目录下的文件夹中。最新版本位于一个名为AdminServer的文件夹下。oracle/Oracle/Middleware/Oracle_Home/user_projects/domains/die_domain/config/deployments/CORP_UI.ear:是一个目录me@corp-box ~$
我想知道舞台目录是什么？为什么应用程序的
浏览 1提问于2018-08-24得票数 0
回答已采纳
cp temp.jar temp.jar^[[D^[[D^[[D^[[D^[[D^[[D^[[D^[[D^[[D-rw-r--r-- 1 root other 488554 Apr 11 02:25 temp.jar
-rw-r--r--22 temp</
浏览 1提问于2014-04-11得票数 0
回答已采纳
我很乐意接受任何关于运行Flink应用程序的建议，因为它看起来有点像雷区。我在这里谈论Linux (Centos 7 dist)，因为我甚至不想分享Windows抛给我的问题。最初，我试着通过maven用lib文件夹存放jars和config文件夹存放属性文件等，这是个灾难，因为它永远找不到任何东西(当通过java - jar启动时)。然后我尝试了maven shade插件来获取一个超级jar (它肯定是一个超级jar)--但是他死了，Flink找不到自己的参数工具依赖项。因此，我们放弃了与java -<
浏览 0提问于2017-12-11得票数 0
3回答
如何从本地存储库中删除项目？我之前使用publish-local SBT命令发布了它。
我想清除所有编译和缓存的东西，因为在重新编译和重新部署到服务器上后，我在项目中看不到任何更改。
浏览 0提问于2013-05-13得票数 9
我正在使用IntelliJ的想法创建一个JAR。我为库JAR选择了“从具有依赖关系的模块中提取”和“提取到目标JAR”--生成的JAR看起来很好： | | +- MANIFEST.MFjar tf myJar.jar
两者都表明所需的类是可用的(也是Main.class)。(注意:当我为库JAR选择“复制到输出文件夹并通过清单链接”时，从该项
浏览 0提问于2018-06-19得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
