講師回答 / 徐老師
failed on connection exception: java.net.ConnectException:? 是連接拒絕的意思,表示這臺機器上的hadoop服務沒有啟動,或者是啟動失敗了,你可以jps查看一下,進程是否都在,如果不在的話需要查看日志排查一下為什么啟動失敗了
2020-02-15
講師回答 / 徐老師
DateUtils代碼:package test.top10;import java.text.SimpleDateFormat;import java.util.Date;/**?* 日期工具類?*/public class DateUtils {? ? private static SimpleDateFormat sdf1 = new SimpleDateFormat("yyyyMMdd");? ? private static SimpleDateFormat sdf2 = new SimpleD...
2020-02-15
最贊回答 / qq_慕斯2033129
/創建靜態內部類MyMapper public static class MyMapper extends Mapper<LongWritable,Text,Text,LongWritable>{ //調用自帶的map()函數 protected void map(LongWritable k1,Text v1,Context context)? throws IOException,InterruptedException{ //k1代表的是每一行的偏移量,v1代表的是每一行的內容...
2020-02-12
講師回答 / 徐老師
hadoop的mapred-site.xml yarn-site.xml core-cite.xml 等配置文件中的配置較多,此課程中暫時沒有針對里面的參數做詳細解釋,如果對這塊感興趣的話可以先到網上查找一下公開資料,后面會有針對hadoop的高級課程會分析里面的參數?
2020-02-08
講師回答 / 徐老師
java.lang.NullPointerException at com.hadoop.dataclean.datacleanmap.map(datacleanmap.java:27)根據這個錯誤提示,可以看出來是datacleanmap.java的第27行代碼出現了空指針異常,這個屬于原始數據有問題了,需要排查一下原始數據還有就是通過System.out.println(id);能在日志中打印出來,說明代碼本身沒有問題,由于某些行的數據有問題導致在解析數據的時候失敗了,這里的數據是json格式的,要仔...
2020-02-05
講師回答 / 徐老師
這里沒法上傳文件,我把數據格式給你發一部分,你可以參考這個格式{"id":"158008900435","uid":"120010010445","nickname":"jack435","gold":445,"watchnumpv":4350,"watchnumuv":870,"hots":1305,"nofollower":435,"looktime":8700,"smlook":2175,"follower":1740,"gifter":870,"length":2610,"area":"A_US"...
2020-01-25
講師回答 / 徐老師
執行ssh-keygen是為了做免密碼登錄的,因為hadoop在啟動的時候默認會使用ssh 命令免密碼登錄到對應的機器啟動集群的相關服務,不管是單機還是集群都是這個流程
2019-12-21