Exception in thread “main” java.lang.AbstractMethodError: org.apache.flink.streaming.api.graph.StreamGraph.getJobGraph()Lorg/apache/flink/runtime/jobgraph/JobGraph;at org.apache.flink.streaming.api.e.

运行flink scala 程序报错：Exception in thread "main" java.lang.NoSuchFieldError: MODEat org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.createLocalEnvironment(StreamExecutionEnvironm...

意思是：该主机状态为待机,不支持操作类别READ.出错的是hadoop的hdfs。你会发现最基本的hdfs命令都不能执行，例如：hadoop fs -ls /自定义的是nn1还是namenode1等自定义名可以在配置文件hdfs-site.xml中查看：<property><name>dfs.ha.namenodes.mycluster</name><va

机器学习：利用计算机从历史中找规律，并把这些规律用到对未来不确定场景的决策机器学习简单分类：可以分为 监督学习、无监督学习、半监督学习分类、聚类、回归生成模型（给出数据属于各个类别的概率）、判别模型（给出数据所属于的类别）机器学习和数据分析的区别:数据特点：交易数据（订单） VS 行为数据（点击历史）少量数据 VS 海量数据采样分析 VS 全量分析训练数据/验证数据/测试数据建模之前把数据分成三个

Docker从1.13版本之后采用时间线的方式作为版本号，分为社区版CE和企业版EE。社区版是免费提供给个人开发者和小型团体使用的，企业版会提供额外的收费服务，比如经过官方测试认证过的基础设施、容器、插件等。社区版按照stable和edge两种方式发布，每个季度更新stable版本，如17.06，17.09；每个月份更新edge版本，如17.09，17.10。一、安装docker1、Docker

运行Flink程序报错，具体信息如下：org.apache.flink.runtime.resourcemanager.exceptions.UnknownTaskExecutorException: No TaskExecutor registered under container_1603071676168_0204_01_000002.at org.apache.flink.runtime

深入理解分布式CAP原理

如何理解flink中state(状态)state泛指state泛指：flink中有状态函数和运算符在各个元素(element)/事件(event)的处理过程中存储的数据（注意：状态数据可以修改和查询，可以自己维护，根据自己的业务场景，保存历史数据或者中间结果到状态(state)中）；使用状态计算的例子：当应用程序搜索某些事件模式时，状态将存储到目前为止遇到的事件序列。在每分钟/小时/天聚合事件时，

在idea中配置运行spark程序报错：scala.Predef$.refArrayOps([Ljava/lang/Object;)Lscala/collection/mutable/ArrayOps;Exception in thread "main" java.lang.NoSuchMethodError: scala.Predef$.refArrayOps([Ljava/lang/Obje.

Apache DS 安装部署@Author：Michealkz镜像下载地址官方下载地址：https://dolphinscheduler.apache.org/zh-cn/download/download.html国内镜像下载地址：# 清华源下载地址https://mirrors.tuna.tsinghua.edu.cn/apache/incubator/dolphinscheduler/1.3