我们使用的是Flink 1.4.1，这是我们的一个项目。我们通过Flink向处理节点发送一些图像处理任务。Flink任务管理器安装在每个处理节点上。我们的主要应用程序将作业发送给Flink作业管理器，Flink作业管理器根据可用性将作业发送给Flink任务管理器。我们实现了一个java应用程序(比如节点应用程序)，Flink在节点上执行这个应用程序。这个应用程序执行我们在处理节点上运行的处理器。这是正常工作的，但是在我们将Flink从1.4.1版本迁移到1.13.2之后，我们收到了下面的错误。
2021-09-30 14:45:56,107 INFO org.apache.flink.run
浏览 38提问于2021-10-01得票数 1
使用DataStream函数创建fromElements函数时出错
以下是-
由: java.io.IOException:未能从源反序列化元素引起。如果正在使用用户定义的序列化(Value和Writable类型)，请检查序列化函数.序列化程序是org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer@599fcdda at org.apache.flink.streaming.api.functions.source.FromElementsFunction.run(FromElementsFunction.java:1
浏览 7提问于2015-12-20得票数 1
当我执行我的Flink应用程序时，它给出了这个NullPointerException：
2017-08-08 13:21:57,690 INFO com.datastax.driver.core.Cluster - New Cassandra host /127.0.0.1:9042 added
2017-08-08 13:22:02,427 INFO org.apache.flink.runtime.taskmanager.Task - TriggerWindow(TumblingEventTimeWindows(30000), List
浏览 5提问于2017-08-08得票数 8
回答已采纳
使用Scala2.12运行Flink 1.9.0并尝试使用将数据发布到Kafka，在本地调试时一切正常。一旦我将作业提交到集群，就会在运行时得到以下java.lang.LinkageError，它无法运行作业：
java.lang.LinkageError: loader constraint violation: loader (instance of org/apache/flink/util/ChildFirstClassLoader) previously initiated loading for a different type with name "org/apache/
浏览 0提问于2020-08-24得票数 1
回答已采纳
1回答
我试图在Flink的DataStream上应用每个窗口的功能。以下是我的代码
DataStream<Tuple2<String, String>> data = ...
DataStream<Tuple2<String, String>> freqCityChangeTransactions = data
.keyBy(0)
.timeWindow(Time.seconds(5))
.process(new MyProcessWindowFunction());
以下是我实现的MyProcessWindowFunction
浏览 1提问于2018-10-01得票数 2
回答已采纳
我试图在Flink中执行的代码的一部分：
val pages = env.readCsvFile[(Long)]("/home/ppi.csv",
fieldDelimiter = "\t", includedFields = Array(1))
我希望将pages用于其他目的，但在编译时，Flink将错误消息抛出如下
线程"main“java.lang.ClassCastException中的异常：
不能将org.apache.flink.api.common.typeinfo.IntegerTypeInfo转换为
org.apache.fli
浏览 4提问于2015-07-08得票数 2
试用的flink版本: 1.4.0、1.4.1、1.4.2
当我尝试制作这个简单的flink应用程序时
val env: StreamExecutionEnvironment =
StreamExecutionEnvironment.getExecutionEnvironment
env.fromElements("a", "b", "c").addSink(new BucketingSink[String]("file:///Users/joshlemer/projects/my-project/target/output&#
浏览 1提问于2018-04-03得票数 2
回答已采纳
我正在尝试计算社交媒体跟踪图中关系的AdamicAdar指数。我使用apache flink-gelly lirbrarie设置我的边、顶点、数据集和图。下面是我的代码： import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.operators.DataSource;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.graph.Graph;
浏览 97提问于2020-09-10得票数 0
我正在尝试做一个POC的Flink状态模式演变。我使用的是Flink 1.15.0和Java 11。我尝试创建3个数据类--每个序列化类型一个：
io.peleg.kryo.User -使用java.time.Instant类，我知道Flink中的POJO序列化不支持这个类。
io.peleg.pojo.User -只使用经典的包装原语- Integer、Long、String。getters、setter和constructors是使用Lombok生成的。
io.peleg.avro.User -使用Avro插件从Avro生成。
对于每个类，我编写了一个流作业，它使用一个
浏览 66提问于2022-07-02得票数 2
最近，我尝试从Flink 1.3.2升级到1.4.0，我遇到了一些问题，无法再导入org.apache.hadoop.fs.{FileSystem, Path}。这一问题发生在两个地方：
ParquetWriter：
import org.apache.avro.Schema
import org.apache.avro.generic.GenericRecord
import org.apache.hadoop.fs.{FileSystem, Path}
import org.apache.flink.streaming.connectors.fs.Writer
import org.apa
浏览 9提问于2017-12-27得票数 2
回答已采纳
在Apache Flink的本地版本中执行以下代码不会生成任何错误，但在远程集群上会生成以下错误！如有任何帮助，我们不胜感激！
personRecords = env.readCsvFile("dataPath/dataset.csv")
.lineDelimiter("\n").fieldDelimiter(",")
.includeFields("11").types(Integer.class, String.class);
partiti
浏览 0提问于2015-12-08得票数 1
2回答
在电子病历上对S3进行闪烁写入
、、、、
我正在尝试写一些输出到S3使用电子病历与Flink。我使用的是Scala 2.11.7、Flink 1.3.2和EMR 5.11。但是，我得到了以下错误：
java.lang.NoSuchMethodError: org.apache.hadoop.conf.Configuration.addResource(Lorg/apache/hadoop/conf/Configuration;)V
at com.amazon.ws.emr.hadoop.fs.EmrFileSystem.initialize(EmrFileSystem.java:93)
at org.apache.fl
浏览 3提问于2018-01-23得票数 1
在使用PyFlink编写Flink 1.15.2代码时，我使用Flink 1.15.2和使用以下连接器从RabbitMQ获取消息：flink-sql-connector-rabbitmq-1.15.2.jar，但是，当我尝试使用以下代码下沉到RabbitMQ时，请按照下面的链接：
stream.add_sink(RMQSink(
connection_config, # config for the RabbitMQ connection
'queueName', # name of the RabbitMQ queue to s
浏览 34提问于2022-09-05得票数 0
我正在尝试将移植到安卓系统。最大的问题之一是，一些java工具并不存在于Android中，但是这些冲突不会在编译时检测到，而错误(NoClassDefFoundError过度)仅在运行时检测到。
例如，Java不存在，但是即使在类中有未解决的符号/库，也不会引发编译错误，特别是：
import javax.management.MBeanServer;
import java.lang.management.BufferPoolMXBean;
import java.lang.management.GarbageCollectorMXBean;
import java.lang.manage
浏览 0提问于2016-04-03得票数 1
回答已采纳
我试图从cassandra表中提取数据作为数据集，但我遇到了两个问题。
首先，cassandraInputFormat只返回一个元组，我更希望没有tuple12，只需要使用pojo来定义它期望返回的内容。因此，我不知道这是否只是我必须接受的东西，是否有一种方法可以使用pojo代替cassandraConnector ()，或者使用cassandraInputFormat不是获取数据的最佳方式。
另一个问题是，即使我从cassandraInputFormat中提取的数据(不管是元组还是非元组)，我也不知道如何将它设置为数据源。对于文件、csv和HDFS，有很多方法()，但没有一个方法显式地用于c
浏览 4提问于2017-05-11得票数 0
回答已采纳
我已经从postgresql DB.then加载了一个规则表作为Flink表，读取kafka msg，并根据这些规则对msg进行分类。代码如下所示 val senv = StreamExecutionEnvironment.getExecutionEnvironment
senv.enableCheckpointing(5000)
val stenv=StreamTableEnvironment.create(senv)
val streamsource=senv.createInput(inputFormat)
stenv.registerDataS
浏览 7提问于2019-09-22得票数 0
我试图在集群上运行Flink作业。这项工作在我的开发(本地)环境上运行良好。但是，当我使用命令将它部署到集群上时：
./bin/flink run -c org.example.CointegrationOfPairs ../coint.jar
如果出现错误，它将失败：
java.lang.NoClassDefFoundError: org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer011
at org.example.CointegrationOfPairs$.main(CointegrationOfPairs
浏览 1提问于2018-07-23得票数 1
回答已采纳
因此，这两种方法的代码是相同的，大致如下：
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
// prepare the topology...
env.execute();
场景是Flink在一台机器上本地运行。
独立罐
pom.xml (相关bits)：
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-core<
浏览 1提问于2019-11-18得票数 1
回答已采纳
我正在尝试为ArangoDB编写一个自定义的ArangoDB。我使用CassandraOutputFormat.java作为灵感，交换了相关的驱动程序和调用等等。我用Java编写了这篇文章，因为我找不到OutputFormat的Scala示例。因此，该类的定义如下：
public class ArangoOutputFormat<OUT extends Tuple> extends RichOutputFormat<OUT>
现在，我想要写入ArangoDB的Flink程序是用Scala编写的。dataset test是DataSet[Tuple2[Long, Long
浏览 3提问于2016-09-09得票数 1
回答已采纳
Flink SQL> INSERT INTO es_sink SELECT 'hello';
[INFO] Submitting SQL update statement to the cluster...
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.tabl
浏览 106提问于2021-06-30得票数 0
1回答
我在flink上有个问题。我实时计算引擎使用groovy脚本扩展计算类型(如:sum、average、、count等)。我们定义了一个标准的计算接口(AbstractCompute)，如果我想在这个框架中扩展一个计算类型，我只需要执行AbstractCompute.and，然后将groovy脚本存储在数据库中。然后，应用程序可以逐个任务地读取脚本，并通过GroovyClassLoader加载到虚拟机中。这个程序不用再用Flink了，看工作做的很好。原因是Flink使用另一个ClassLoader (FlinkUserCodeClassLoaders$ChildFirstClassLoader)
浏览 2提问于2019-01-14得票数 2
使用flink版本1.13.1
我写了一个自定义的度量报告，但在我的flink中似乎不起作用。启动flink时，JobManager显示警告日志，如下所示：
2021-08-25 14:54:06,243 WARN org.apache.flink.runtime.metrics.ReporterSetup [] - The reporter factory (org.apache.flink.metrics.kafka.KafkaReporterFactory) could not be found for reporter kafka. Available f
浏览 10提问于2021-08-25得票数 2
回答已采纳
我已经使用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
我在Mac上运行Apache Flink 1.4.2 (没有捆绑hadoop)，并且我已经设法运行了WordCount示例。但是，当我尝试按照中的说明运行Gelly示例时，我遇到了以下错误：
java.lang.ClassNotFoundException: org.apache.flink.graph.generator.random.BlockInfo
我可以知道怎样才能修好它吗？
我首先通过以下方式启动了集群
./bin/start-cluster.sh
Starting cluster.
[INFO] 1 instance(s) of jobmanager are already
浏览 0提问于2018-03-14得票数 0
我现在已经设置了Flink，并在EMR上运行了一个作业，现在我正试图通过将指标发送到prometheus来添加监视。
在EMR上运行Flink遇到了一个问题。我使用Terraform来提供EMR (我在下载和运行作业之后运行ansible )。打开盒子，它看起来不像EMR的Flink发行版包括可选的jars (flink-指标-prometheus，flink-cep等等)。
看看弗林克的文档，上面写着
“要使用此记者，必须将/opt/flink-metrics-prometheus-1.6.1.jar复制到Flink发行版的/lib文件夹”
但是，当登录到EMR主节点时，/etc/f
浏览 0提问于2019-03-06得票数 4
回答已采纳
我有一个带有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反序列化程序中，我从getProducedType方法中得到以下错误：
com.esotericsoftware.kryo.KryoException: java.lang.NullPointerException
Serialization trace:
values (org.apache.avro.generic.GenericData$Record)
at com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:125)
at com.esotericsoftware
浏览 31提问于2018-01-03得票数 3
回答已采纳
1回答
闪烁序列化错误
、、
我正在尝试在我的Apache Flink Gelly图上运行标签传播协议。
下面是我的代码：
Graph<String, Long, String> ugraph = Graph.fromDataSet(vertex, edgeSet, env).getUndirected();
DataSet<Tuple2<String, Long>> idsWithInitialLabels = DataSetUtils
.zipWithUniqueId(graph.getVertexIds())
浏览 2提问于2016-07-27得票数 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
当我试图在上执行示例时，我会得到以下错误。
通过在的帮助下添加一些额外的参数，我成功地执行了文档中的第一个命令。
user@local:~/flink-1.14.4$ ./bin/kubernetes-session.sh \
-Dkubernetes.cluster-id=dproc-example-flink-cluster-id \
-Dtaskmanager.memory.process.size=4096m \
-Dkubernetes.taskmanager.cpu=2 \
-Dtaskmanager.numberOfTaskSlots=4 \
-Dresourcemanager.
浏览 31提问于2022-03-25得票数 1
我正在使用以下脚本提交flink申请，
flink run -m yarn-cluster -c com.my.flink.learningflink.FlinkToMySQL -yn 4 -ys 1 -j /tmp/learing.flink.1.7.1-0.1.jar
我的类FlinkToMySQL在learing.flink.1.7.1-0.1.jar中，但我的应用程序也需要依赖于mysql jar，我如何指定mysql jar和其他依赖的jar。
此外，我还使用以下脚本尝试了-yt选项
flink run -m yarn-cluster -c com.my.flink.learn
浏览 0提问于2019-10-11得票数 1
2回答
只是尝试从flink 1.3迁移到1.4，并在linux机器上遇到此异常：(不能在windows上重现)。
我还导入了这个包：
// https://mvnrepository.com/artifact/org.apache.flink/flink-shaded-hadoop2
compile group: 'org.apache.flink', name: 'flink-shaded-hadoop2', version: '1.4.0'
有什么帮助吗？
在flink控制台：
TriggerWindow(TumblingProcessingTim
浏览 22提问于2018-02-13得票数 1
我在maven/java项目中使用flink，需要在创建的jar内部包含我的信任。
因此，我在我的pom文件中添加了以下内容。这包括jar中的所有yml信任(位于src/main/resources文件夹中)，其名称在执行时将作为参数传递。
<resources>
<resource>
<directory>src/main/resources</directory>
<includes>
<include>**/*.y
浏览 0提问于2019-08-14得票数 0
回答已采纳
1回答
问题是在进行案例类提取时，映射函数中存在问题。case类不可序列化。我已经隐式地定义了DefaultFormats格式。
package org.apache.flink.quickstart
import java.util.Properties
import com.fasterxml.jackson.databind.{JsonNode, ObjectMapper}
import com.fasterxml.jackson.module.scala.DefaultScalaModule
import org.apache.flink.api.scala._
import org.apa
浏览 3提问于2017-05-02得票数 1
回答已采纳
我们最近正在将flink集群升级到版本1.9.1。出现hadoop s3a相关错误。消息如下。 2020-01-16 08:39:49,283 ERROR org.apache.flink.runtime.blob.BlobServerConnection - PUT operation failed
org.apache.flink.fs.shaded.hadoop3.org.apache.hadoop.fs.UnsupportedFileSystemException: No FileSystem for scheme "file"
at o
浏览 44提问于2020-01-16得票数 0
在flink项目中，我使用case类单击。
case class click( date: LocalDateTime, stbId:String, channelId :Int)
这个类填充了DataSets，并且在日期为java 8 java.time.LocalDateTime的情况下工作得很好。在java7环境中切换到org.joda (版本2.9)之后，对DataSets中的click对象的调用没有像以前那样执行。访问单击对象的日期字段的某些函数会引发NullPointerExceptions。这些函数的例子是getHourOfDay、toString等。我能够确保click类的da
浏览 11提问于2015-11-11得票数 4
回答已采纳
1回答
flink网站上的文档以及AWS的Flink部署都说我的配置在flink-conf.yaml文件中，但是我应该将这个文件存储在我的项目中的什么地方，以及如何让flink获取它？ 特别是，我想启用检查点，当我的项目树如下所示时，我该如何做： .
├── pom.xml
└── src
├── main
│ ├── java
│ │ └── xyz
│ │ └── foobar
│ │ └── foo
│ │ └── Main.java
│ └── re
浏览 222提问于2021-05-05得票数 1
回答已采纳
我有一个Flink会话集群(作业管理器+任务管理器)，版本为1.11.1，配置了log4j-控制台属性，包括Kafka appender。另外，在作业管理器和任务管理器中，我都支持flink-s3-fs-hadoop内置插件。
我将kafka客户端jar添加到flink/lib目录中，这是容器运行所必需的。但是，在实例化S3插件(并初始化记录器)时，我仍然会得到以下类加载错误。
由: org.apache.kafka.common.config.ConfigException:无效值org.apache.kafka.common.serialization.ByteArraySerialize
浏览 2提问于2020-12-06得票数 3
1回答
嗨，我正在尝试运行一个flink scala应用程序，它从kafka读取，应用一些查找转换，然后写到kafka。
Flink版本1.12.1
我在当地测试过，效果很好。但是，当我尝试使用原生kubernetes集成在集群上运行它时，我会看到下面这样的奇怪错误。
集群看起来也很好，因为我试图在集群上运行一个wordcount应用程序，它运行得很好。
异常不清楚，堆栈跟踪也显示了任务管理器堆栈跟踪，因此不知道应用程序中的问题可能在哪里。这可能是序列化问题吗？是否有一种方法来调试这些问题，并在应用程序代码中找到有问题的实际点？
org.apache.flink.streaming.runtime.t
浏览 2提问于2021-09-01得票数 0
回答已采纳
在集成测试中测试flink mini集群上的流时，我遇到了一个问题。该流映射一个生成的Avro Java类( SpecificRecord )。 流作业是用Scala编写的。 flink运行时正在崩溃，因为它无法实例化org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils 下面是堆栈跟踪： stack: java.lang.ClassCastException: class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils
java.lang.RuntimeE
浏览 38提问于2020-09-25得票数 0
1回答
我想在flink流处理作业中将对象序列化为Json。在flink作业中，所有对象都需要可序列化。
我用杰克逊来序列化我的对象。
final ObjectMapper mapper = new ObjectMapper();
mapper.registerModule(new JodaModule());
mapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
当我使用它时，我会得到以下例外：
java.io.NotSerializableException: com.fasterxml.jackson.datatype.j
浏览 8提问于2016-12-08得票数 0
回答已采纳
1回答
我使用Flink DataStreams来加入两个流(一个是图书流，一个是出版商流)。我正在尝试使用evictor删除元素，以防它们被从数据库中删除，这由变量deleted表示。 当我在没有evictor的情况下运行代码时，它工作得很好，但是当我添加evictor时，它失败了。 DataStream<BooksWithPublishers> book_publisher = bookStream
.join(publishStream)
.where(value -> value.publisherId)
.equalTo(v
浏览 17提问于2021-04-30得票数 0
回答已采纳
我是斯卡拉的新人。因此，我想在Java中处理Apache的DataSet。但是我在Scala代码中有一个DataSet，我想在Java的方法中传递它。例如:在Scala中：
val dS: DataSet[Vector] = ...
SampleJavaClass.sendDS(ds)
在SampleJavaClass.java中有一个类似于sendDs(DataSet<Vector> javaDs)的方法
我正在尝试这样做，但是显示错误消息:类型不匹配；找到：
org.apache.flink.api.scala.DataSetorg.apache.flink.ml.math.
浏览 5提问于2016-02-27得票数 4
回答已采纳
1回答
我的问题非常类似于，只是这个问题对于Java来说，我需要在Scala中得到答案。我在IntelliJ中复制粘贴了所提供的解决方案，它将复制粘贴的片段自动转换为Scala，然后我对它进行了编辑，以适应我的代码。我仍然会得到编译错误(甚至在编译IntelliJ能够检测到代码的问题之前)。基本上，提供给keyBy (keySelector的getKey函数的返回值)的参数不匹配任何重载版本的keyBy函数所期望的参数。
查找了KeySelector的许多scala代码示例，该示例返回一个复合键，但没有找到任何示例。
import org.apache.flink.api.java.functions
浏览 0提问于2018-12-29得票数 0
回答已采纳
1回答
我正在Scala中构建一个Apache应用程序，它从Kafka总线读取流数据，然后对其执行汇总操作。Kafka的数据是Avro格式的，需要一个特殊的反序列化类。我找到了这个scala类AvroDeserializationScehema ()：
package org.myorg.quickstart
import org.apache.avro.io.BinaryDecoder
import org.apache.avro.io.DatumReader
import org.apache.avro.io.DecoderFactory
import org.apache.avro.reflec
浏览 1提问于2018-07-01得票数 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应用程序，它从kafka中读取并将其吸收到kafka。
当我从Intellij运行应用程序时，没有问题，但是当我将ClassCastException提交给flink集群时，它会给出shadowJar。我能在找出我在这里做错了什么方面得到一些帮助吗？
异常跟踪：
Caused by: java.lang.ClassCastException: cannot assign instance of org.apache.kafka.clients.consumer.OffsetResetStrategy to field org.apache.flink.connector.ka
浏览 61提问于2022-05-16得票数 4
我有一个在Spring应用程序中运行的Flink应用程序。应用程序无法在Flink集群中作为jar运行。我能够将应用程序作为一个jar运行在我的本地windows计算机(迷你集群)上。
异常堆栈跟踪如下所示：
org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: null
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:54
浏览 0提问于2019-06-30得票数 2
我正在使用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
我尝试将我的应用程序部署到cli纱线上的flink，不幸的是，它在下面的例外情况下失败了
java.lang.NoClassDefFoundError: Lredis/clients/jedis/JedisCluster;
at java.lang.Class.getDeclaredFields0(Native Method)
at java.lang.Class.privateGetDeclaredFields(Class.java:2583)
at java.lang.Class.getDeclaredFields(Class.java:1916)
at o
浏览 3提问于2018-03-22得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
