错误：java。lang.ClassNotFoundException：组织。json4s。运行flink作业时的默认格式
我使用flink-1.4.2与scala。同时运行我的代码与flink。我得到错误：
java.lang.RuntimeException: Could not look up the main(String[]) method from the class org.example.WindowExample: org/json4s/DefaultFormats$
Caused by: java.lang.NoClassDefFoundError: org/json4s/DefaultFormats$
Caused by: java.lang.ClassNotFoundException: org.json4s.DefaultFormats$
共有1个答案
将json4s依赖项添加到pom中。xml，如果已经存在，则将其范围设置为编译。
-
我试图在hadoop中运行一个程序，但我一直得到: 线程“main”java.lang.unsupportedClassVersionError：hadoop_project_16/aggregatejob：不支持major.minor版本52.0在java.lang.ClassLoader.DefineClass1（本机方法）在java.lang.ClassLoader.DefineClass（
-
我正在kubernetes上试用最新版本的Flink1.5的flink工作。 我的问题是如何在上面的flink集群上运行一个示例应用程序。flink示例项目提供了如何使用flink应用程序构建docker映像并将该应用程序提交给flink的信息。我遵循了这个例子，只是把flink的版本改成了最新版本。我发现应用程序（example-app）提交成功，并且在kubernetes的pod中显示，但是f
-
我正试图使用scoop将数据从MySQL数据库导入到hdfs中，但我得到了“没有为ClassWriter生成的列”错误。 下面是我的独家命令： 下面是错误堆栈： 20/03/08 16:11:27错误Manager.SqlManager：执行com.mysql.jdbc.exceptions.jdbc4.CommunicationsException语句时出错：通信链接失败 最后一个成功发送到服务
-
当我与Kafka·Flink一起进行概念验证时，我发现了以下几点：似乎Kafka制作人的错误可能会由于Flink方面的工作量而发生？！ 以下是更多细节： 我有样本文件，如样本？？。EDR由约700000行组成，具有“实体”、“值”、“时间戳”等值 我使用以下命令创建kafka主题： 我使用以下命令加载主题的示例文件： 我有一些在flink方面的工作，这些工作通过6小时和72小时的滑动窗口为每个实体
-
信息zookeeper.clientcnxn：打开到服务器debashis-pseudo-hadoop/127.0.1.1:22181的套接字连接。不会尝试使用SASL进行身份验证（未知错误） 14/06/17 13:07:28警告Zookeeper.clientcnxn:会话0x0，因为服务器为空，出现意外错误，正在关闭套接字连接并试图重新连接
-
我们正在尝试在K8s集群上部署apache Flink作业，但我们注意到一个奇怪的行为，当我们开始我们的作业时，任务管理器内存以分配的数量开始，在我们的例子中是3 GB。 最终，内存开始减少，直到达到约160 MB，此时，它会恢复一点内存，所以不会达到其极限。 这种非常低的内存通常会导致作业因任务管理器心跳异常而终止，即使在尝试查看Flink仪表板上的日志或执行作业流程时也是如此。 为什么它的内存