在Apache Flink服务器上的何处可以找到我使用Apache Flink仪表板提交的jar
在Apache Flink服务器上，可以通过Flink的Web界面找到您使用Apache Flink仪表板提交的jar。该Web界面通常可以通过以下地址访问：http://<Flink服务器IP地址>:8081。
在Flink的Web界面中，您可以找到以下信息：
- 任务视图：显示正在运行的任务和已完成的任务的状态、进度和统计信息。
- 作业视图：显示已提交的作业的状态、进度和统计信息。
- 任务管理器视图：显示连接到Flink集群的任务管理器的状态和资源使用情况。
- 日志和异常视图：显示作业的日志和异常信息，帮助您进行故障排除和调试。
- Flink配置视图：显示Flink集群的配置信息，包括任务管理器的数量、内存分配等。
要找到您使用Apache Flink仪表板提交的jar，您可以按照以下步骤操作：
- 打开浏览器，输入Flink服务器的IP地址和端口号（默认为8081）。
- 在登录界面中输入您的用户名和密码（如果有）。
- 登录后，您将进入Flink的Web界面。
- 导航到作业视图，您将看到已提交的作业列表。
- 在作业列表中，找到您提交的作业，并点击该作业的链接。
- 在作业详情页面中，您将找到有关该作业的详细信息，包括提交的jar文件。
请注意，具体界面和步骤可能会因Flink的版本和配置而有所不同。以上答案适用于一般情况，如果您使用的是特定版本的Flink或有特定配置，请参考相关文档或官方指南以获取准确的信息。
推荐的腾讯云相关产品：腾讯云容器服务（Tencent Kubernetes Engine，TKE），是一种高度可扩展的容器管理服务，可帮助您在腾讯云上轻松部署、管理和扩展容器化应用。TKE提供了强大的容器编排和调度功能，可与Flink等大数据处理框架集成，实现高效的数据处理和分析。了解更多信息，请访问：https://cloud.tencent.com/product/tke
相关·内容
我开发了一个Flink作业，并使用Apache Flink仪表板提交了我的作业。根据我的理解，当我提交作业时，我的jar应该在Flink服务器上可用。我试着找出我的jar的路径，但不能。Flink是否将这些jar文件保存在服务器上？如果有，我在哪里可以找到？有什么文档吗？请帮帮忙。谢谢!
浏览 19提问于2018-08-21得票数 2
回答已采纳
我正在研究方向，将现有的风暴拓扑转换为flink作业。我通过git安装了flink 1.0 (快照)，并且在本地运行git服务器和流服务器。
我通过gradle将拓扑构建到一个.jar文件中，并通过flink web接口提交它，并得到以下消息：“没有指定的条目类”。
所以-错过了一个入口？.jar需要什么特别的东西吗？舱单？
当提交到风暴集群时，此.jar正在工作。我添加了(看起来像)相关的flink .jar文件。
编辑：
通过cmd行提交作业给我显示了以下消息：
org.apache.flink.client.program.ProgramInvocationException:文件中
浏览 2提问于2015-10-25得票数 3
回答已采纳
我已经创建了一个CICD进程来在flink服务器中部署我的flink应用程序。CD管道能够成功添加Jar，但无法提交jar。我检查了CD日志，发现了我在flink- 500 internal server error日志中检查过的服务器，在那里我发现了这个错误 Error while opening jar file '/tmp/flink-web-<someid>/flink-web-upload' 下面是完整的错误堆栈跟踪 2020-10-23 15:16:10,344 ERROR org.apache.flink.runtime.webmonitor.han
浏览 163提问于2020-10-25得票数 0
2回答
在编译我运行的包之后，我在本地集群上运行Flink。
flink run -c com.gurustreams.flink.EntryPoint \
/Users/jeremy.zhang/workspace/guru-streams/flink/target/scala-2.11/guru-streams-flink-assembly-0.0.1.jar \
--stream-name KafkaReadExample
并得到了以下错误：
Could not build the program from JAR file.
我还试图从jar仪表板上运行Flink文件，并发现了
浏览 0提问于2018-09-20得票数 4
回答已采纳
1回答
我是巴泽尔的新手。我需要使用Bazel下载外部依赖jar文件。在何处配置以下载外部jar文件。我试图在构建文件和工作区文件中添加jar文件，但不起作用。
工作空间文件
maven_server(name="myserver",url="https://mvnrepository.com/artifact/org.apache.flink/flink-java")
maven_jar(name="flink-java",artifact="org.apache.flink:filnk-java:jar:1.2.0",server=&
浏览 2提问于2017-04-07得票数 0
我试图使用Kafka作为输入和输出来执行apache- trying单词计数。但是在将jar提交到flink集群时，出现了这个错误- The RemoteEnvironment cannot be used when submitting a program through a client, or running in a TestEnvironment context.
org.apache.flink.streaming.api.environment.RemoteStreamEnvironment.<init>(RemoteStreamEnvironment.ja
浏览 93提问于2020-07-13得票数 0
使用beam 2.6与Flink 1.5.3一起运行测试。横梁运行本地flink流道没有问题。但无法在flink集群上运行。尝试mvn和flink提交该职务。当使用mvn运行时，我使用：
mvn clean package -Pflink-runner exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount -Dexec.args="--runner=FlinkRunner --flinkMaster=c2:6123 --filesToStage=target/word-count-beam-bundled-0.1.j
浏览 0提问于2018-09-21得票数 1
我已经使用Scala2.11.7创建了一个带有Apache 1.0.3的应用程序，我想在本地测试它(单个FLink )。因此，我按照网站上的说明执行了以下操作：
./bin/start-local.sh
tail log/flink-*-jobmanager-*.log
它启动得很好，我可以在localhost:8081上看到web界面。然后，我试图提交我的申请，但我得到了一个异常或奇怪的消息。例如，当我键入以下任一命令时：
./bin/flink run ./myApp.jar
./bin/flink run ./myApp.jar -c MyMain
./bin/flink run ./m
浏览 2提问于2016-05-26得票数 4
1回答
我正在将flink(v1.10.0)作业提交到我的群集，但显示以下错误： System.out: (none)
System.err: (none)
at org.apache.flink.client.program.OptimizerPlanEnvironment.generateException(OptimizerPlanEnvironment.java:149)
at org.apache.flink.client.program.OptimizerPlanEnvironment.getPipeline(OptimizerPlanEnvironment.java:
浏览 57提问于2020-04-05得票数 0
回答已采纳
我试图连接卡夫卡与Flink和运行通过sql-client.sh。但是，无论我如何处理.yaml和库，我都会得到错误：
Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exception. This is a bug. Please consider filing an issue.
at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:201)
浏览 46提问于2021-11-30得票数 0
回答已采纳
更新
为了提供一些上下文，使用LZ4压缩启用了Kafka主题。
当识别压缩类型时，尝试将LZ4与运行时由于某种原因可以找到的KafkaLZ4BlockInputStream相关联。
@Override
public InputStream wrapForInput(ByteBuffer inputBuffer, byte messageVersion, BufferSupplier decompressionBufferSupplier) {
try {
return new KafkaLZ4BlockInputStream(inputBuffer, decompres
浏览 18提问于2021-12-09得票数 1
在Flink SQL上使用带有Kerberos身份验证的Kafka数据源，Flink的本地测试已经通过，但当我将任务推到纱线上时，错误消息提示无法找到Kafka的JAAS文件！
与Flink SQL相关的代码如下：
create table source_sensor(
id VARCHAR,
ts bigint,
vc double)
WITH (
'connector' = 'kafka',
'topic' = 'huangfu_0110'
浏览 23提问于2022-01-24得票数 1
我正尝试在本地环境中运行Apache Flink作业，当我提交jar时，我收到内部服务器错误。我查看了日志文件，但找不到任何有关这方面的信息。
以下是屏幕截图：
浏览 0提问于2019-07-16得票数 0
1回答
我有用于flink作业的简单java代码
List<Tuple2> list = new ArrayList<>();
for (int i = 0; i < 10; i++) {
list.add(new Tuple2(Integer.valueOf(i), "test" + i));
}
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.fromCollection(list).print();
env
浏览 2提问于2020-06-16得票数 0
我正在从AWS控制台(使用Add )启动EMR中的Flink作业，并希望传递JVM参数。根据Flink文档，我们应该按照下面的方式传递args。
flink run -m yarn-cluster -p 2 /home/hadoop/flink-0.0.1-SNAPSHOT.jar -yD env.java.opts="-Dspring.profiles.active=dev -Djob.name=Flink_Job_1 -Dkafka.brokers:<>:9092" -yid application_1591030260237_0047
我有两个问题
flink
浏览 18提问于2020-06-23得票数 0
1回答
我的目标是建立一个高吞吐量集群，使用Kafka作为源，使用Flink作为流处理引擎。这就是我所做的。
我已经在主服务器和工作人员上设置了一个2节点集群，配置如下。
主flink-flink.Master
jobmanager.rpc.address: <MASTER_IP_ADDR> #localhost
jobmanager.rpc.port: 6123
jobmanager.heap.mb: 256
taskmanager.heap.mb: 512
taskmanager.numberOfTaskSlots: 50
parallelism.default: 100
W
浏览 7提问于2015-08-28得票数 9
回答已采纳
需要帮助！谁能给我指引一条正确的路？
以下是我的代码和日志的片段。
DataStream<ObjectNode> stream = env.addSource(KafkaConsumer.getKafkaConsumer());
DataStream<MyDataObject> dataStream = stream.flatMap(new DataTransformation());
我使用flatMapFunction来处理我的输入对象并获得多个对象。
以下是stackTrace：
java.lang.RuntimeException: Buffer pool is
浏览 8提问于2018-01-16得票数 4
我在发布标签上:EMR-6.7.0 Hadoop发行版:Amazon3.2.1应用程序:Livy 0.7.1，ZooKeeper 3.5.7，Flink 1.14.2
我也在每个emr-6.X版本中尝试过这一点，并得到了相同的错误。
我试图提交一个简单的flink步骤，使用添加一个步骤，在电子病历上使用args，flink-session -d。
如果出现以下错误，则会失败。
2022-09-22 02:06:08,883 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Shutting YarnS
浏览 57提问于2022-09-22得票数 1
我有一个带有Yarn的Flink集群，使用flink-quickstart-java原型构建一个演示项目。在使用'mvn干净包-Pbuild‘命令构建了一个胖jar之后，并使用'flink run -m丝- -yn 2./flink-快照-1.0.jar’提交程序后，程序会抛出以下异常：
org/apache/kafka/common/serialization/ByteArrayDeserializer : org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09.setDeserializer(Fli
浏览 1提问于2019-08-05得票数 3
1回答
我有一个flink工作，它消耗kafka的数据，做一些无状态的平面图，并产生数据到kafka，这是一个非常低的工作量的工作。
它通常会毫无问题地获取检查点，直到作业需要从检查点恢复为止，例如，它只是无法恢复具有下面堆栈跟踪的状态。
状态很小，我相信它只是卡夫卡的偏移量，它是用AT_LEAST_ONCE语义运行的。
所有的运算符都设置了.uid()，我完全没有想法。
这是尝试从检查点重新启动时出现的错误：
java.lang.Exception: Exception while creating StreamOperatorStateContext.
at org.apache.flin
浏览 3提问于2021-06-10得票数 0
我有一个容器化的flink集群，具有独立的JobManager和2个任务管理器。当我提交一个包含我需要的连接器和代码的胖jar时，一切都会正常运行，但是一个只有我的代码的jar将失败--尽管我已经将连接器jar添加到/opt/flink/lib，容器进程显示它们将被添加到类路径中。当我试图从IDE进行远程连接时，也会发生同样的失败；不用说，每次都要打包一个胖jar，这会带来糟糕的开发体验。
我需要做什么才能让flink理解我放置在/opt/flink/lib中的额外jars应该与所有新作业一起使用？
类加载程序异常：
org.apache.flink.streaming.runtime.ta
浏览 0提问于2019-04-12得票数 1
回答已采纳
运行以下命令将作业提交给纱线，但不需要任务管理器的分配数。集群有足够的资源<220 enough，720 G mem>
/data/clusterserver/flink-1.7.2/bin/flink run -m yarn-cluster -yn 4 -ys 2 /data/clusterserver/flink-1.7.2/examples/batch/WordCount.jar --input hdfs:///tmp/wordcount.txt --output hdfs:///tmp/count.result
2019-04-10 15:04:57,397 INFO
浏览 0提问于2019-04-10得票数 4
回答已采纳
我目前有一个运行在独立Kubernetes (v1.16)中的Flink (1.12)集群。出于我们的目的，我们采用了application cluster模式部署。 为了使我们的flink集群对故障更有弹性，我们希望将HA添加到我们当前的设置中，我已经阅读了文档，并遵循了为我们的给定设置(here)推荐的示例配置。 flink-conf.yaml jobmanager.rpc.address: {{ $fullName }}-jobmanager
jobmanager.rpc.port: 6123
jobmanager.memory.process.size: 1600m
浏览 77提问于2021-08-24得票数 0
目前有一项规定可以从Flink仪表板上传jars。这是一个手工过程。有什么方法可以通过maven命令来自动化这个过程吗？类似于Apache如何拥有flink-runner，您可以在其中打包您的maven项目，并且可以使用maven命令本身提交它。
浏览 4提问于2017-09-19得票数 0
回答已采纳
我正在尝试理解在zookeeper升级期间flink作业管理器的行为是否是预期的。 我在kubernetes中运行flink 1.11.2，使用zookeeper服务器3.5.4-beta。当我进行zookeeper升级时，zookeeper有20秒的停机时间。我希望flink作业在这20秒内重新启动，或者在日志中显示一些警告。相反，我看到整个flink JVM崩溃(后来pod重启)。 我以为flink会在内部重试zookeeper请求，所以我很惊讶它崩溃了。这是意料之中的，还是说这是一个bug？ 从日志中 org.apache.flink.shaded.zookeeper3.org.apa
浏览 75提问于2021-02-09得票数 0
回答已采纳
在将Flink升级到1.7.2之后，当我尝试从仪表板提交作业时，作业出现了一些问题，作业提交会失败，并出现以下错误。
Exception occurred in REST handler: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
关于这份工作没有提交的原因，没有给出其他理由。1.4.2的情况并非如此。是否有办法了解作业未能部署的全部原因？我在日志中也看到了同样的错误，没有其他信息。
浏览 1提问于2019-05-16得票数 0
回答已采纳
1回答
版本: cdh(6.2.1)，flink(1.13.1)，kafka(2.1.0-cdh6.2.1) 数据管道:kafka(源) -> flink -> kafka(宿) 提交的作业运行正常。在I savepoint之后，当我通过savepoint恢复它时发生异常。 2021-11-22 16:39:52,556 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job Flink Streaming Job (daf7707813d79b884b2c7b1897801248) swit
浏览 566提问于2021-11-23得票数 0
我尝试在Flink (版本1.14.0)上使用可查询状态，但不幸的是，我一直收到以下错误： 2021-11-07 11:10:55,795 ERROR org.apache.flink.queryablestate.network.AbstractServerHandler [] - Error while handling request with ID 1
java.lang.OutOfMemoryError: Direct buffer memory
at java.nio.Bits.reserveMemory(Bits.java:175) ~[?:?]
at java
浏览 31提问于2021-11-07得票数 0
我目前正在使用Flink 1.7 +gcs-连接器库。我试图让StreamingFileSink写到GCS桶中，并遇到以下异常：
我遇到了一个Jira： --但我不清楚代码是否曾经合并过。
在需要做什么方面有什么帮助是非常感谢的，以使这一工作？
java.lang.UnsupportedOperationException: Recoverable writers on Hadoop are only supported for HDFS and for Hadoop version 2.7 or newer
at org.apache.flink.runtime.fs.hdfs.Ha
浏览 3提问于2019-12-03得票数 1
回答已采纳
我使用Flink v.1.13.2来管理一个工作经理，三个任务经理。
由于某些原因(我无法找出原因)，任务管理器连接正在丢失。下面是我找到的日志：
2022-02-17 21:19:55,891 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Sink: Print to Std. Out (13/32) (f0ff88713cc3ff5ce39e7073468abed4) switched from RUNNING to FAILED on 1.2.3.5:39309-f61daa @ serve
浏览 32提问于2022-02-18得票数 0
我试图提交一个已经打包在JAR中的flink作业。基本上，它使用了一个受SASL身份验证保护的kafka主题，因此它需要一个.jks文件，我已经将其包含在JAR中，并在代码中读到如下：
try(InputStream resourceStream = loader.getResourceAsStream(configFile)){
properties.load(resourceStream);
properties.setProperty("ssl.truststore.location",
loader.getReso
浏览 31提问于2021-12-10得票数 1
回答已采纳
我已经通过curl将一个jar (它是通过word程序生成的)通过HTTP请求上传到Apache Flink web控制台，get显示了上传的jar。
当我尝试使用该jar提交作业时，它会抛出以下错误：
由: org.apache.flink.client.program.ProgramInvocationException: JAR文件不存在'/tmp/flink-web-8aa36f99-87fb-4fbc-b155-237fd833fc32/:949611ce-345a-4cd5-986b-8ff9b0700852_WordCount.jar‘引起的
我的帖子请求是这样的
浏览 2提问于2018-01-17得票数 1
回答已采纳
我试图使用以下命令作为AWS EMR中的一个步骤提交一个jar：
aws emr add-steps --cluster-id j-XXXXXXXXX --steps Type=CUSTOM_JAR,Name=test-job,ActionOnFailure=CONTINUE,Jar=s3://xxxx/frauddetection-0.1.jar,Args=flink-yarn-session,-d
它是一个基本的EMR集群，Flink 1.14.2和JDK 8作为一个步骤添加了这一点，给出了错误：
java.lang.NoSuchMethodError:org.apache.common
浏览 27提问于2022-04-01得票数 3
我使用flink监控hdfs中的新文件(文件为gzip格式)，并对其进行处理。 env.readFile(filePath) 它可以在文件有效时工作， 但如果gzip文件无效，flink作业将被终止。 有异常日志： java.io.IOException: Error opening the Input Split hdfs://mdw:8020/user/data/15_077_4.gz [0,-1]: Not in GZIP format
at org.apache.flink.api.common.io.FileInputFormat.open(FileInputFormat.
浏览 77提问于2021-04-17得票数 0
回答已采纳
我刚开始使用flink，我正在实现一个模式识别模块(不使用CEP实现模式匹配)，它将从EventHub主题读取json流，如果模式匹配，则推送到另一个事件中心主题。我的模块功能如下
从接收JSON负载
I使用的是一个RichSourceFunction，它将从API读取模式并发送到广播流
我正在使用Flink BroadcastProcessFunction来根据广播状态中可用的模式列表来处理数据，并且我没有使用键流或我的程序中的任何状态，因为没有状态的范围，我只需要检查某些值是否存在于JSON .中。
我读到flink在内部维护状态，即使没有状态显式实现
下面的设置为检查点，我平均每小时收到
浏览 8提问于2021-01-29得票数 0
我正在尝试创建到oracle数据库的Flink JBDC接收器。当在本地运行时(从junit测试和minicluster)，它可以工作，但是当部署在k8s中时，它会抛出一个异常，说它找不到合适的驱动程序。Classpath是：
Classpath: /flink/lib/flink-cep-scala_2.12-1.13.5-stream1.jar:/flink/lib/flink-connector-jdbc_2.12-1.13.5.jar:/flink/lib/flink-csv-1.13.5-stream1.jar:/flink/lib/flink-json-1.13.5-stream1
浏览 16提问于2022-05-24得票数 1
回答已采纳
我需要提交一个flink sql程序来运行纱线，
我根据flink官方网站打包的
在flink目录下将依赖项添加到/lib时，它正常工作，但如果我希望从jar包加载依赖项，而不是在/lib下加载依赖项
java.lang.NoClassDefFoundError将在我执行flink run时发生
这是我的pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:x
浏览 64提问于2021-12-13得票数 1
闪烁:1.13.1 配置单元:2.1.1-cdh6.2.1 flink/lib目录中的jar包如下所示。enter image description here当我执行sql-client.sh时，我得到以下错误，这要求我向Apache Flink社区提交评论。 Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exception. This is a bug. Please consider filing an issue.
at
浏览 229提问于2021-10-27得票数 0
我尝试在本地部署的Flink Docker集群上部署一个Apache光束管道。 管道失败，出现以下错误 The RemoteEnvironment cannot be instantiated when running in a pre-defined context (such as Command Line Client, Scala Shell, or TestEnvironment)
org.apache.flink.api.java.RemoteEnvironmentConfigUtils.validate(RemoteEnvironmentConfigUtils.java:52)
浏览 80提问于2020-08-20得票数 1
我正在开发一个Java应用程序，它在Flink 1.14上使用UDF。我使用PipelineOptions.JARS配置在应用程序代码中动态添加包含UDF类的jar文件，但是应用程序无法使用ClassNotFoundException从配置好的jar文件加载UDF类。
我也尝试过PipelineOptions.CLASSPATHS，它失败时有完全相同的错误和堆栈跟踪。
如果使用“Flink run”和"-C“选项来更新类路径，通过flink CLI提交的应用程序jar工作得很好：
<FLINK_HOME>/bin/flink run --detached -C file:/
浏览 20提问于2021-12-15得票数 0
1回答
嗨，我正在尝试运行一个flink scala应用程序，它从kafka读取，应用一些查找转换，然后写到kafka。
Flink版本1.12.1
我在当地测试过，效果很好。但是，当我尝试使用原生kubernetes集成在集群上运行它时，我会看到下面这样的奇怪错误。
集群看起来也很好，因为我试图在集群上运行一个wordcount应用程序，它运行得很好。
异常不清楚，堆栈跟踪也显示了任务管理器堆栈跟踪，因此不知道应用程序中的问题可能在哪里。这可能是序列化问题吗？是否有一种方法来调试这些问题，并在应用程序代码中找到有问题的实际点？
org.apache.flink.streaming.runtime.t
浏览 2提问于2021-09-01得票数 0
回答已采纳
在向Flink运行时提交JAR时，我遇到了一个特殊的问题。我有一个Flink流JAR要运行。当我提交JAR时，我得到了以下异常。 org.apache.flink.streaming.runtime.tasks.StreamTaskException: Could not instantiate outputs in order.
at org.apache.flink.streaming.api.graph.StreamConfig.getOutEdgesInOrder(StreamConfig.java:470)
at org.apache.flink.streaming
浏览 32提问于2021-10-27得票数 0
当StreamingFileSink尝试重命名进程中的文件时，我偶尔会遇到一个问题。请参见下面的异常：
文件系统挂载在Google Cloud Storage buckets上。它在大多数情况下都工作得很好，但突然失败了。
我已经验证了inprogress文件是否存在。任何提示和建议都将非常有用--谢谢！
2019-11-12 01:26:44.908 [flink-akka.actor.default-dispatcher-77] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job kafka-ingestio
浏览 25提问于2019-11-12得票数 0
我正在跟踪，以便在本地Kubernetes中启动会话。
首先，我创建了一个干净的新集群。
但是，在运行之后
./bin/kubernetes-session.sh -Dkubernetes.cluster-id=my-first-flink-cluster
刚创建的pod my-first-flink-cluster-xxx日志中出现了错误：
2021-08-14 18:33:02,519 WARN io.fabric8.kubernetes.client.dsl.internal.WatchConnectionManager [] - Exec Failure: HTTP 403, Sta
浏览 7提问于2021-08-14得票数 2
回答已采纳
1回答
我使用的是flink 1.5.1，一个集群对应一个作业
我用CLI提交一个作业，然后取消它，有一件事是我不能理解的
:~/flink-1.5.1/bin$ ./flink run -d -m yarn-cluster -ynm lz_test_alone1 -ytm 4096 -yjm 1024 -c Demo /home/test/flink1.5_demo-1.1-SNAPSHOT.jar
2018-08-10 15:05:28,390 INFO org.apache.flink.yarn.cli.FlinkYarnSessionCli - Fou
浏览 11提问于2018-08-10得票数 0
我目前正在尝试将Flink嵌入到一个Play Framework项目中。但是，当我尝试执行Flink文档中的WordCount示例时，我得到了这个错误：
play.api.http.HttpErrorHandlerExceptions$$anon$1: Execution exception[[JobExecutionException: Cannot initialize task 'DataSink (collect())': Deserializing the OutputFormat (org.apache.flink.api.java.Utils$CollectHel
浏览 12提问于2016-09-02得票数 2
我已经设置了一个flink独立集群，它有一个主服务器和三个从服务器，都是SESU Linux机器。在主仪表板中，我可以看到3个任务管理器和3个任务槽，因为我已经在所有从设备中的flink-conf.yaml中设置了taskmanager.numberOfTaskSlots: 1。
当我运行一个flink内置程序时，比如/streaming/Iteration.jar，我得到的异常经常是
java.io.IOException: Connecting the channel failed: Connecting to remote task manager + 'ccr202/127.0
浏览 1279提问于2018-04-03得票数 1
我正在使用apache flink 1.10批量计算我的流数据，今天我将我的apache flink kubernetes(v1.15.2) pod从机器1移动到机器2，发现所有提交任务记录和任务列表都消失了，发生了什么？峰会记录还在记忆中吗？重启apache flink的kubernetes pod时，如何保存提交记录和任务列表？我只发现checkpoint persistant，但没有关于任务的。
如果丢失了正在运行的任务历史，我必须上传我的任务jar并重新创建所有任务，如果丢失了历史，那么多任务需要重新创建，有没有可能自动恢复任务？
浏览 4提问于2020-04-30得票数 0
我正在使用flink和kafka，我得到了这个错误。
java.lang.NoSuchMethodError: scala.Predef$.ArrowAssoc(Ljava/lang/Object;)Ljava/lang/Object;
at kafka.consumer.FetchRequestAndResponseMetrics.<init>(FetchRequestAndResponseStats.scala:32)
at kafka.consumer.FetchRequestAndResponseStats.<init>(FetchRequest
浏览 2提问于2016-06-30得票数 4
我正在尝试使用我的felipeogutierrez/explore-flink:1.11.1-scala_2.12镜像可用here到kubernetes集群配置中，就像它说here一样。我用maven编译了我的项目https://github.com/felipegutierrez/explore-flink，并用这个Dockerfile扩展了默认的flink图像flink:1.11.1-scala_2.12 FROM maven:3.6-jdk-8-slim AS builder
# get explore-flink job and compile it
COPY ./java/expl
浏览 89提问于2020-09-21得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
