spark版本2.3。distribute by cast(rand()*400 as int)应该生成400个文件。当前只有255个文件，多次执行结果一样，想知道是什么原因(partition的数量

MvQL中读写数据1.准备/1a.建库create database test01;create database test02;b.test01库中建表create table user(id in

初学spark，使用spark structred stream进行计算统计，2小时窗口时长，10秒钟触发一次计算，kafka里发送几条测试数据，内存就报OOM了，按理说不应该啊，请问问题是出在哪儿？

@Override public boolean open(long partitionId, long epochId) { //System.out.println("

搭建spark的yarn运行模式，并且截图将wordcount打成的jar包，提交到spark的yarn模式client、cluster集群上运行，截图运行结果 安装IDEA，使用scala语言

上课学搭建伪分布式时格式化出错

现在程序开发好多都是培训机构自学，初期都不清楚项目怎么编写怎么描述，就算找到某个项目也不知道从何开始讲起，更不清楚如何讲给面试官听，请各路大神前来发言！！！

错误内容如下： java.lang.NullPointerException at com.microsoft.jdbc.sqlserver.tds.TDSRPCParameter.init

ERROR [Executor task launch worker for task 0] - Exception in task 0.0 in stage 0.0 (TID 0) java.lan

今天开启 NameNode 和 DataNode 守护进程时出错但是JAVA环境变量已经配好了，终端输入java -version也会显示版本信息 报错为：localhost: Error: JAVA

就比如kafka推送数据后，spark从kafka中拉取数据，再计算。 我直接写消费者 ，计算不行吗？两者到底啥区别？

换了好多次pom插件依然 ：Failed to load class com.atguigu.bigdata.spark.wordcount. 有没有大佬帮忙解决一下鸭

安装spark时依照老师所录制的视频一步一步走的，但是不知道为啥么第五行以后的内容跟视频里的不一样

select pt_d,prodname,count(*) as 会员数From Xgroup by pt_d,prodname 现在想在这基础上加一列价格。select pt_d,prodnam

用的hive本来是select A,B,count（）as Cgroup by A,B from X现在想加一列Dselect A,B,count（） as C,DFrom Xgroup by A,B