{"id":2302,"date":"2023-05-07T18:25:30","date_gmt":"2023-05-07T10:25:30","guid":{"rendered":"https:\/\/aic.leexinghai.com\/?p=2302"},"modified":"2023-10-03T10:49:36","modified_gmt":"2023-10-03T02:49:36","slug":"sparkinst8","status":"publish","type":"post","link":"https:\/\/www.leexinghai.com\/aic\/sparkinst8\/","title":{"rendered":"H30507-\u5b9e\u9a8c8-Spark\u914d\u7f6e\u6559\u7a0b\u548c\u7f16\u7a0b\u5b9e\u8df5"},"content":{"rendered":"\n

\u672c\u6587\u5206\u4e24\u4e2a\u90e8\u5206\uff0c\u7b2c\u4e00\u4e2a\u90e8\u5206\u4e3aSpark\u914d\u7f6e\u6559\u7a0b\uff08\u56e0\u4e3aXMU\u7684\u914d\u7f6e\u592a\u8001\u4e86\uff0c\u8fd9\u91cc\u6362\u4e86\u7248\u672c\uff0c\u5728\u8fd9\u91cc\u7b80\u5355\u8bb0\u5f55\u4e00\u4e0b\uff0c\u540c\u65f6\u4e5f\u89e3\u51b3\u4e86\u8001\u5e08\u4e0a\u8bfe\u65f6\u63d0\u51fa\u7684\u89e3\u51b3\u8b66\u544a\u7684\u95ee\u9898\uff09\uff1b\u7b2c\u4e8c\u4e2a\u90e8\u5206\u4e3a\u5e7f\u5dde\u5546\u5b66\u9662\u5927\u6570\u636e\u5e94\u7528\u6280\u672f\u8bfe\u7a0b\u5b9e\u9a8c8\u62a5\u544a\u53c2\u8003\u6559\u7a0b\u5185\u5bb9\u3002<\/p>\n\n\n\n

\u7b2c\u4e00\u90e8\u5206\uff1aSpark\u914d\u7f6e\u6559\u7a0b<\/h2>\n\n\n\n

\u8f6f\u4ef6\u7248\u672c\uff1aHadoop\uff1a3.1.3\uff08\u4f7f\u7528\u672c\u4eba\u5236\u4f5c\u7684\u865a\u62df\u673a\u5219\u7248\u672c\u76f8\u540c\uff09 | Spark\uff1a3.0.0\uff08\u4e0d\u8981\u4f7f\u7528XMU\u63d0\u4f9b\u76842.4.0<\/strong><\/mark>\uff09| Linux\uff1aUbuntu23.04\uff08\u539f\u724816\u90a3\u4e2a\u5e94\u8be5\u4e5f\u884c\uff09<\/p>\n\n\n\n

\u4e0b\u8f7d\u5730\u5740\u4f20\u9001\uff1aIndex of \/dist\/spark\/spark-3.0.0 (apache.org)<\/a><\/p>\n\n\n\n

1.\u5728\u4e0a\u9762\u7684\u5730\u5740\u4e2d\u4e0b\u8f7dSpark3.0.0-bin-without-hadoop.tgz\u5230\u5bb6\u76ee\u5f55\u4e0b\uff0c\u4f7f\u7528tar\u547d\u4ee4\u89e3\u538b\u5230\/usr\/local\u6587\u4ef6\u5939\u4e0b\uff1b\u7136\u540e\u66f4\u6539\u540d\u5b57\u4e3aspark\uff1b\u4e3ahadoop\u7528\u6237\u589e\u52a0\u6743\u9650\uff1b\u5c06\u914d\u7f6e\u6a21\u677f\u6587\u4ef6\u6539\u540d\u5220\u9664\u3010.template\u3011\u5b57\u6bb5\uff0c\u4f7f\u5176\u6210\u4e3a\u6b63\u5f0f\u914d\u7f6e\u6587\u4ef6\uff0c\u7f16\u8f91\u914d\u7f6e\u6587\u4ef6\uff0c\u914d\u7f6e\u547d\u4ee4\u5982\u56fe1\u6240\u793a\u3002<\/p>\n\n\n

\n
\"\"
\u56fe1<\/figcaption><\/figure>\n<\/div>\n\n\n

2.\u7f16\u8f91\u914d\u7f6e\u6587\u4ef6\uff1a\u5728\u7a7a\u884c\u589e\u52a0\u5982\u56fe2\u6240\u793a\u7684\u5185\u5bb9\u3002<\/p>\n\n\n

\n
\"\"
\u56fe2<\/figcaption><\/figure>\n<\/div>\n\n\n

3.\u6b64\u65f6\u53ef\u4ee5\u901a\u8fc7spark\u76ee\u5f55\u4e0b\u7684bin\/spark-shell\u76f4\u63a5\u542f\u52a8spark\uff0c\u8fd9\u91cc\u4f1a\u51fa\u73b0\u4e24\u4e2a\u8b66\u544a\uff1a\u5206\u522b\u662f\uff081\uff09\u4e3b\u673a\u540d\u88ab\u89e3\u6790\u6210127.0.1.1\uff0c\u5efa\u8bae\u901a\u8fc7\u865a\u62df\u673a\u7684\u9759\u6001IP\u5730\u5740\u8fdb\u884c\u66ff\u6362\uff1b\uff082\uff09\u4e0d\u80fd\u52a0\u8f7d\u672c\u5730hadoop\u5e93\uff0c\u5728\u53ef\u7528\u524d\u4f7f\u7528builtin-java\u7c7b\u6765\u66ff\u6362\uff0c\u8b66\u544a\u5185\u5bb9\u5982\u56fe3\u6240\u793a\u3002<\/p>\n\n\n

\n
\"\"
\u56fe3<\/figcaption><\/figure>\n<\/div>\n\n\n

4.\u5bf9\u4e8e\u8b66\u544a1\uff0c\u53ef\u4ee5\u5728spark-env.sh\uff08\u56fe1\u7d2b\u8272\u90e8\u5206\u547d\u4ee4\u5904\uff09\uff0c\u589e\u52a0\u5982\u56fe4\u6240\u793a\u7684\u5b57\u6bb5\uff0c\u901a\u8fc7\u6307\u5b9aSPARK_LOCAL_IP=\u60a8\u865a\u62df\u673a\u7684\u9759\u6001IP\u5730\u5740\u6765\u89e3\u51b3\u3002<\/p>\n\n\n

\n
\"\"
\u56fe4<\/figcaption><\/figure>\n<\/div>\n\n\n

5.\u5bf9\u4e8e\u8b66\u544a2\uff0c\u53ef\u4ee5\u901a\u8fc7vim \/etc\/profile <\/code>\uff0c\u589e\u52a0\u5982\u56fe5\u6240\u793a\u7684\u5b57\u6bb5\uff0c\u901a\u8fc7\u6307\u5b9ahadoop\u5e93\u6587\u4ef6\u8def\u5f84\u6765\u89e3\u51b3\u3002<\/p>\n\n\n

\n
\"\"
\u56fe5<\/figcaption><\/figure>\n<\/div>\n\n\n

6.\u5b8c\u6210\u7b2c5\u6b65\u540e\uff0c\u4f7f\u7528source \/etc\/profile<\/code>\u8fdb\u884c\u6587\u4ef6\u7f16\u8bd1\uff0c\u4f7f\u5176\u914d\u7f6e\u751f\u6548\u3002\u6b64\u65f6\u91cd\u65b0\u8fd0\u884c spark\/bin\/spark-shell<\/code>\uff0c\u91cd\u65b0\u542f\u52a8spark shell\uff0c\u53ef\u4ee5\u53d1\u73b0\u8b66\u544a\u5df2\u7ecf\u88ab\u89e3\u51b3\uff0c\u5982\u56fe6\u6240\u793a\u3002<\/p>\n\n\n

\n
\"\"
\u56fe6<\/figcaption><\/figure>\n<\/div>\n\n\n

7.\u5b89\u88c5sbt\uff1a\u5148\u5b89\u88c5curl\u7ec4\u4ef6\uff1asudo apt install curl <\/code>\u7136\u540e\u590d\u5236\u5982\u4e0b\u547d\u4ee4\uff1a<\/p>\n\n\n\n

echo \"deb https:\/\/repo.scala-sbt.org\/scalasbt\/debian all main\" | sudo tee \/etc\/apt\/sources.list.d\/sbt.list\n\necho \"deb https:\/\/repo.scala-sbt.org\/scalasbt\/debian \/\" | sudo tee \/etc\/apt\/sources.list.d\/sbt_old.list\n\ncurl -sL \"https:\/\/keyserver.ubuntu.com\/pks\/lookup?op=get&search=0x2EE0EA64E40A89B84B2DF73499E82A75642AC823\" | sudo apt-key add\n\nsudo apt-get update\n\nsudo apt-get install sbt\n<\/code><\/pre>\n\n\n\n
\u5982\u56fe7\u6240\u793a\u3002<\/p>\n\n\n
\n
\"\"
\u56fe7<\/figcaption><\/figure>\n<\/div>\n\n\n
8.\u5b8c\u6210\u5b89\u88c5\u540e\uff0c\u8f93\u5165sbt\uff0c\u4f1a\u8fdb\u884csbt\u7684\u914d\u7f6e\uff0c\u4f8b\u5982\u4e0b\u8f7dsbt\u542f\u52a8\u5668\u7b49\uff0c\u5982\u56fe8\u6240\u793a\uff1b\u5b8c\u6210\u4e0b\u8f7d\u7684\u7ed3\u679c\u5982\u56fe9\u6240\u793a\u3002<\/p>\n\n\n
\n
\"\"
\u56fe8<\/figcaption><\/figure>\n<\/div>\n\n
\n
\"\"
\u56fe9<\/figcaption><\/figure>\n<\/div>\n\n\n
9.\u5728spark\u76ee\u5f55\u4e0b\u521b\u5efa\u7b80\u5355\u6587\u4ef6\u5939\uff0c\u4ee5\u4fbf\u540e\u7eed\u4f7f\u7528\uff0c\u521b\u5efa\u547d\u4ee4\u548c\u6587\u4ef6\u7ed3\u6784\u5982\u56fe10\u6240\u793a\u3002<\/p>\n\n\n
\n
\"\"
\u56fe10<\/figcaption><\/figure>\n<\/div>\n\n\n
10.\u5728\u521b\u5efa\u597d\u7684ch10_shell\u4e0b\u521b\u5efa\u4e00\u4e2ahw1.txt\u6587\u4ef6\uff0c\u968f\u610f\u8f93\u5165\u4e00\u4e9b\u5185\u5bb9\u7528\u4e8e\u7edf\u8ba1\u6587\u4ef6\u884c\u6570\uff0c\u53c2\u8003\u6548\u679c\u5982\u56fe11\uff0c\u56fe12\u6240\u793a\u3002<\/p>\n\n\n
\n
\"\"
\u56fe11<\/figcaption><\/figure>\n<\/div>\n\n
\n
\"\"
\u56fe12<\/figcaption><\/figure>\n<\/div>\n\n\n
11.\u5728spark\u4ea4\u4e92\u754c\u9762\u4f7f\u7528\u547d\u4ee4\u8fdb\u884c\u672c\u5730\u64cd\u4f5c\uff0c\u901a\u8fc7\u547d\u4ee4 val textFile=sc.textFile(\"file:\/\/\u865a\u62df\u673a\u672c\u5730\u6587\u4ef6\u8def\u5f84\") <\/code>\u521b\u5efa\u4e00\u4e2a\u53d8\u91cftextFile\uff0c\u7136\u540e\u4f7f\u7528textFile.count()<\/code>\u8fdb\u884c\u6587\u672c\u884c\u6570\u7edf\u8ba1\uff0c\u7ed3\u679c\u5982\u56fe13\u6240\u793a\u3002<\/p>\n\n\n
\n
\"\"
\u56fe13<\/figcaption><\/figure>\n<\/div>\n\n\n
12.\u4f7f\u7528 \/usr\/local\/hadoop\/sbin\/start-all.sh<\/code>\u542f\u52a8hadoop\u3002\u7136\u540e\u901a\u8fc7mkdir\u547d\u4ee4\u548cput\u547d\u4ee4\u521b\u5efa\u4e00\u4e9b\u6587\u4ef6\u5939\uff0c\u5c06\u521a\u521a\u521b\u5efa\u597d\u7684hw1.txt\u6587\u4ef6\u4e0a\u4f20\u5230hdfs\u4e2d\uff0c\u547d\u4ee4\u5982\u56fe14\u6240\u793a\u3002<\/p>\n\n\n
\n
\"\"
\u56fe14<\/figcaption><\/figure>\n<\/div>\n\n\n
13.\u5728spark\u4ea4\u4e92\u754c\u9762\u4f7f\u7528\u547d\u4ee4\u8fdb\u884chdfs\u64cd\u4f5c\uff0c\u901a\u8fc7 val \u81ea\u5df1\u968f\u4fbf\u5b9a\u4e49\u53d8\u91cf\u540d=sc.textFile(\"hdfs\u8def\u5f84\")<\/code> \u81ea\u5df1\u968f\u4fbf\u5b9a\u4e49\u53d8\u91cf\u540d.count() <\/code>\u53ef\u4ee5\u8bbf\u95eehdfs\u7684\u6587\u4ef6\u5e76\u8fdb\u884c\u76f8\u5e94\u64cd\u4f5c\uff0c\u547d\u4ee4\u5982\u56fe15\uff0c\u56fe16\u6240\u793a\u3002<\/p>\n\n\n
\n
\"\"
\u56fe15<\/figcaption><\/figure>\n<\/div>\n\n
\n
\"\"
\u56fe16<\/figcaption><\/figure>\n<\/div>\n\n\n
[2023-10-03\u66f4\u65b0]14.\u5982\u679chdfs\u8bfb\u53d6\u62a5\u9519,\u5219\u9700\u8981\u624b\u52a8\u6dfb\u52a0hdfs\u7684\u8def\u5f84,\u5982\u56fe16-1\u6240\u793a,\u5982\u679chdfs\u8def\u5f84\u88ab\u4fee\u6539\u8fc7,\u5219\u9700\u8981\u5728hdfs\u6839\u6587\u4ef6\u5939\u524d\u6dfb\u52a0hdfs:\/\/IP\u5730\u5740:\u7aef\u53e3\u53f7 <\/strong>\u6765\u89e3\u51b3(\u5177\u4f53\u53ef\u4ee5\u53c2\u89c1\u60a8HADOOP\u7684core-site.xml\u6587\u4ef6).<\/p>\n\n\n
\n
\"\"
\u56fe16-1<\/figcaption><\/figure>\n<\/div>\n\n\n
\u7b2c\u4e8c\u90e8\u5206\uff1a\u5e7f\u5dde\u5546\u5b66\u9662\u5927\u6570\u636e\u5e94\u7528\u6280\u672f\u8bfe\u7a0b\u5b9e\u9a8c8\u62a5\u544a\u53c2\u8003\u6559\u7a0b\u5185\u5bb9<\/h2>\n\n\n\n
\u4e00\u3001\u5b9e\u9a8c\u76ee\u7684<\/strong><\/strong><\/p>\n\n\n\n
    \n
  1. \u638c\u63e1\u4f7f\u7528Spark\u8bbf\u95ee\u672c\u5730\u6587\u4ef6\u548cHDFS\u6587\u4ef6\u7684\u65b9\u6cd5\uff1b<\/li>\n\n\n\n
  2. \u638c\u63e1Spark\u5e94\u7528\u7a0b\u5e8f\u7684\u7f16\u5199\u3001\u7f16\u8bd1\u548c\u8fd0\u884c\u65b9\u6cd5\u3002<\/li>\n<\/ol>\n\n\n\n
    \u4e8c\u3001\u5b9e\u9a8c\u4eea\u5668\u8bbe\u5907\u6216\u6750\u6599<\/strong><\/p>\n\n\n\n
      \n
    • JDK 1.8<\/li>\n\n\n\n
    • Eclipse 2019-12(R)<\/li>\n\n\n\n
    • Hadoop 3.3.1(\u672c\u4f8b\u4f7f\u75283.1.3)<\/li>\n\n\n\n
    • Spark 3.2.0(\u672c\u4f8b\u4f7f\u75283.0.0)<\/li>\n\n\n\n
    • Sbt 1.5.5(\u672c\u4f8b\u4f7f\u75281.8.2)<\/li>\n\n\n\n
    • Maven 3.8.3\uff08\u672c\u4f8b\u672a\u4f7f\u7528\uff09<\/li>\n<\/ul>\n\n\n\n
      \u4e09\u3001\u5b9e\u9a8c\u539f\u7406<\/strong><\/strong><\/p>\n\n\n\n
      \"\"<\/figure>\n\n\n\n
      \"\"<\/figure>\n\n\n\n
      \u56db\u3001\u5b9e\u9a8c\u5185\u5bb9\u4e0e\u6b65\u9aa4<\/strong><\/strong><\/p>\n\n\n\n
        \n
      1. Spark\u8bfb\u53d6\u6587\u4ef6\u7cfb\u7edf\u7684\u6570\u636e<\/strong><\/li>\n\n\n\n
      2. \u5728spark-shell\u4e2d\u8bfb\u53d6Linux\u7cfb\u7edf\u672c\u5730\u6587\u4ef6\u201c\/home\/hadoop\/test.txt\u201d\uff0c\u7136\u540e\u7edf\u8ba1\u51fa\u6587\u4ef6\u7684\u884c\u6570\uff1b<\/li>\n\n\n\n
      3. \u5728spark-shell\u4e2d\u8bfb\u53d6HDFS\u7cfb\u7edf\u6587\u4ef6\u201c\/user\/hadoop\/test.txt\u201d\uff08\u5982\u679c\u8be5\u6587\u4ef6\u4e0d\u5b58\u5728\uff0c\u8bf7\u5148\u521b\u5efa\uff09\uff0c\u7136\u540e\uff0c\u7edf\u8ba1\u51fa\u6587\u4ef6\u7684\u884c\u6570\uff1b<\/li>\n\n\n\n
      4. \u7f16\u5199\u72ec\u7acb\u5e94\u7528\u7a0b\u5e8f\uff08\u63a8\u8350\u4f7f\u7528Scala\u8bed\u8a00\uff09\uff0c\u8bfb\u53d6HDFS\u7cfb\u7edf\u6587\u4ef6\u201c\/user\/hadoop\/test.txt\u201d\uff08\u5982\u679c\u8be5\u6587\u4ef6\u4e0d\u5b58\u5728\uff0c\u8bf7\u5148\u521b\u5efa\uff09\uff0c\u7136\u540e\uff0c\u7edf\u8ba1\u51fa\u6587\u4ef6\u7684\u884c\u6570\uff1b\u901a\u8fc7sbt\u5de5\u5177\u5c06\u6574\u4e2a\u5e94\u7528\u7a0b\u5e8f\u7f16\u8bd1\u6253\u5305\u6210 JAR\u5305\uff0c\u5e76\u5c06\u751f\u6210\u7684JAR\u5305\u901a\u8fc7 spark-submit \u63d0\u4ea4\u5230 Spark \u4e2d\u8fd0\u884c\u547d\u4ee4\u3002<\/strong><\/li>\n\n\n\n
      5. \u7f16\u5199\u72ec\u7acb\u5e94\u7528\u7a0b\u5e8f\u5b9e\u73b0\u6570\u636e\u53bb\u91cd:\u5bf9\u4e8e\u4e24\u4e2a\u8f93\u5165\u6587\u4ef6A\u548cB\uff0c\u7f16\u5199Spark\u72ec\u7acb\u5e94\u7528\u7a0b\u5e8f\uff08\u63a8\u8350\u4f7f\u7528Scala\u8bed\u8a00\uff09\uff0c\u5bf9\u4e24\u4e2a\u6587\u4ef6\u8fdb\u884c\u5408\u5e76\uff0c\u5e76\u5254\u9664\u5176\u4e2d\u91cd\u590d\u7684\u5185\u5bb9\uff0c\u5f97\u5230\u4e00\u4e2a\u65b0\u6587\u4ef6C\u3002<\/strong><\/li>\n\n\n\n
      6. \u7f16\u5199\u72ec\u7acb\u5e94\u7528\u7a0b\u5e8f\u5b9e\u73b0\u6c42\u5e73\u5747\u503c\u95ee\u9898:\u6bcf\u4e2a\u8f93\u5165\u6587\u4ef6\u8868\u793a\u73ed\u7ea7\u5b66\u751f\u67d0\u4e2a\u5b66\u79d1\u7684\u6210\u7ee9\uff0c\u6bcf\u884c\u5185\u5bb9\u7531\u4e24\u4e2a\u5b57\u6bb5\u7ec4\u6210\uff0c\u7b2c\u4e00\u4e2a\u662f\u5b66\u751f\u540d\u5b57\uff0c\u7b2c\u4e8c\u4e2a\u662f\u5b66\u751f\u7684\u6210\u7ee9\uff1b\u7f16\u5199Spark\u72ec\u7acb\u5e94\u7528\u7a0b\u5e8f\u6c42\u51fa\u6240\u6709\u5b66\u751f\u7684\u5e73\u5747\u6210\u7ee9\uff0c\u5e76\u8f93\u51fa\u5230\u4e00\u4e2a\u65b0\u6587\u4ef6\u4e2d\u3002<\/strong><\/li>\n<\/ol>\n\n\n\n
        \u4e94\u3001\u5b9e\u9a8c\u7ed3\u679c\u4e0e\u5206\u6790<\/strong><\/strong><\/p>\n\n\n\n
          \n
        1. \u5728spark-shell\u4e2d\u8bfb\u53d6Linux\u7cfb\u7edf\u672c\u5730\u6587\u4ef6\u201c\/home\/hadoop\/test.txt\u201d\uff0c\u7136\u540e\u7edf\u8ba1\u51fa\u6587\u4ef6\u7684\u884c\u6570\uff1b<\/li>\n<\/ol>\n\n\n\n
          1.1\u5728\u4efb\u610f\u5730\u65b9\u521b\u5efatest.txt(\u672c\u4f8b\u540d\u79f0\u4e3ahw1.txt),\u5e76\u4efb\u610f\u8f93\u5165\u5185\u5bb9\u3002\u53c2\u8003\u547d\u4ee4\u53ca\u5185\u5bb9\u5982\u56fe1\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe1<\/figcaption><\/figure>\n<\/div>\n\n\n
          1.2\u4f7f\u7528count()\u5c5e\u6027\u5bf9\u672c\u5730\u6587\u4ef6\u8fdb\u884c\u884c\u6570\u7edf\u8ba1\uff0c\u7ed3\u679c\u5982\u56fe2\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe2<\/figcaption><\/figure>\n<\/div>\n\n\n
          2.\u5728spark-shell\u4e2d\u8bfb\u53d6HDFS\u7cfb\u7edf\u6587\u4ef6\u201c\/user\/hadoop\/test.txt\u201d\uff08\u5982\u679c\u8be5\u6587\u4ef6\u4e0d\u5b58\u5728\uff0c\u8bf7\u5148\u521b\u5efa\uff09\uff0c\u7136\u540e\uff0c\u7edf\u8ba1\u51fa\u6587\u4ef6\u7684\u884c\u6570\uff1b<\/p>\n\n\n\n
          2.1\u5728hdfs\u4e0a\u521b\u5efa\u4e00\u4e2ach10\u6587\u4ef6\u5939\uff1b\u5728\u5176\u5b50\u76ee\u5f55\u4e0b\u521b\u5efainput_shell\u6587\u4ef6\u5939\uff1b\u4f7f\u7528-put\u547d\u4ee4\u5c06\u7b2c1\u6b65\u7684\u6587\u4ef6\u4e0a\u4f20\uff0c\u547d\u4ee4\u5982\u56fe3\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe3<\/figcaption><\/figure>\n<\/div>\n\n\n
          2.2\u4f7f\u7528count()\u5c5e\u6027\u5bf9hdfs\u7684\u6587\u4ef6\u8fdb\u884c\u884c\u6570\u7edf\u8ba1\uff0c\u7ed3\u679c\u5982\u56fe4\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe4<\/figcaption><\/figure>\n<\/div>\n\n\n
          3.\u7f16\u5199\u72ec\u7acb\u5e94\u7528\u7a0b\u5e8f\uff08\u63a8\u8350\u4f7f\u7528Scala\u8bed\u8a00\uff09\uff0c\u8bfb\u53d6HDFS\u7cfb\u7edf\u6587\u4ef6\u201c\/user\/hadoop\/test.txt\u201d\uff08\u5982\u679c\u8be5\u6587\u4ef6\u4e0d\u5b58\u5728\uff0c\u8bf7\u5148\u521b\u5efa\uff09\uff0c\u7136\u540e\uff0c\u7edf\u8ba1\u51fa\u6587\u4ef6\u7684\u884c\u6570\uff1b\u901a\u8fc7sbt\u5de5\u5177\u5c06\u6574\u4e2a\u5e94\u7528\u7a0b\u5e8f\u7f16\u8bd1\u6253\u5305\u6210 JAR\u5305\uff0c\u5e76\u5c06\u751f\u6210\u7684JAR\u5305\u901a\u8fc7 spark-submit \u63d0\u4ea4\u5230 Spark \u4e2d\u8fd0\u884c\u547d\u4ee4\u3002<\/h4>\n\n\n\n
          3.1\u5728spark\u6587\u4ef6\u5939\u4e0b\u521b\u5efasparkapps\/ch10_scala\/src\/main\/scala \u7cfb\u5217\u6587\u4ef6\u5939\uff0c\u7136\u540e\u5230scala\u6587\u4ef6\u5939\u4e0b\uff0c\u521b\u5efaHW10_1_CountLine.scala\u6587\u4ef6\uff0c\u5728ch10_scala\u6587\u4ef6\u5939\u4e0b\u521b\u5efaHW10_1_CountLine.sbt\u6587\u4ef6\uff0c\u547d\u4ee4\u5982\u56fe5\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe5<\/figcaption><\/figure>\n<\/div>\n\n\n
          3.2\u5bf9\u4e8eHW10_1_CountLine.scala\u6587\u4ef6\uff0c\u5185\u5bb9\u5982\u56fe6\u6240\u793a\uff0c\u5bf9\u4e8eHW10_1_CountLine.sbt\u6587\u4ef6\uff0c\u5185\u5bb9\u5982\u56fe7\u6240\u793a\uff1b\u9700\u8981\u6ce8\u610f\u7684\u662f\uff1ahdfs\u8def\u5f84\u5c31\u662fhadoop\/etc\/hadoop\/core-site.xml\u91cc\u9762\u7684hdfs\u6587\u4ef6\u8def\u5f84\uff08\u672c\u4f8b\u53ca\u672c\u4eba\u8bbe\u8ba1\u7684\u865a\u62df\u673a\u4e3a192.168.245.5:9810\uff0c\u540c\u65f6sbt\u6587\u4ef6\u4e2d\u7684scala-version\u548cspark-core\u7248\u672c\u4e3a2.12.10\u4e0e3.0.0\uff0c\u60a8\u5982\u679c\u4f7f\u7528\u60a8\u81ea\u5df1\u914d\u7f6e\u7684\u865a\u62df\u673a\uff0c\u5219\u6539\u6210\u5bf9\u5e94\u60a8\u865a\u62df\u673a\u4e2d\u7684\u7248\u672c\u3002\u4e0b\u4e0d\u518d\u8d58\u8ff0\uff09<\/p>\n\n\n
          \n
          \"\"
          \u56fe6<\/figcaption><\/figure>\n<\/div>\n\n
          \n
          \"\"
          \u56fe7<\/figcaption><\/figure>\n<\/div>\n\n\n
          3.3\u7f16\u8f91\u5b8c\u6210\u540e\uff0c\u4f7f\u7528sbt package<\/code>\u8fdb\u884c\u6253\u5305\u3002\u7b2c\u4e00\u6b21\u53ef\u80fd\u9700\u8981\u5f88\u4e45\u624d\u80fd\u4e0b\u8f7d\u5b8c\u6210\uff08\u5982\u679c\u60a8\u4e0d\u5728\u4e2d\u56fd\u5927\u9646\u5219\u4f1a\u975e\u5e38\u5feb\uff09\uff0c\u5982\u56fe8\u6240\u793a\uff08\u4e0b\u8f7d\u4e864118\u79d2\uff0c\u5373\u4e3a1\u5c0f\u65f68\u5206\u949f38\u79d2\uff09\uff1b\u5982\u679c\u9047\u5230AccessDenied\u62a5\u9519\uff0c\u5219\u8bf7\u5c06sparkapps\u6587\u4ef6\u5939\u7684\u6743\u9650\u8bbe\u7f6e\u4e3a777<\/strong>.<\/p>\n\n\n
          \n
          \"\"
          \u56fe8<\/figcaption><\/figure>\n<\/div>\n\n\n
          3.4\u6253\u5305\u5b8c\u6210\u540e\uff0c\u4f1a\u5728target\/scala-2.12\u6587\u4ef6\u5939\u770b\u5230\u4e00\u4e2ajar\u6587\u4ef6\uff0c\u5982\u56fe9\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe9<\/figcaption><\/figure>\n<\/div>\n\n\n
                  3.5\u4f7f\u7528spark-submit<\/code>(\u672a\u914d\u7f6e\u73af\u5883\u53d8\u91cf\u5219\u5728spark\u7684bin\u76ee\u5f55\u4e0b)\uff0c\u8fdb\u884chdfs\u6587\u4ef6\u884c\u6570\u7edf\u8ba1\uff0c\u53ef\u4ee5\u83b7\u5f97\u8f93\u51fa\u7ed3\u679c\u3002\u53c2\u8003\u547d\u4ee4\u53ca\u7ed3\u679c\u5982\u56fe10\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe10<\/figcaption><\/figure>\n<\/div>\n\n\n
          4.\u7f16\u5199\u72ec\u7acb\u5e94\u7528\u7a0b\u5e8f\u5b9e\u73b0\u6570\u636e\u53bb\u91cd<\/h4>\n\n\n\n
          \u5bf9\u4e8e\u4e24\u4e2a\u8f93\u5165\u6587\u4ef6A\u548cB\uff0c\u7f16\u5199Spark\u72ec\u7acb\u5e94\u7528\u7a0b\u5e8f\uff08\u63a8\u8350\u4f7f\u7528Scala\u8bed\u8a00\uff09\uff0c\u5bf9\u4e24\u4e2a\u6587\u4ef6\u8fdb\u884c\u5408\u5e76\uff0c\u5e76\u5254\u9664\u5176\u4e2d\u91cd\u590d\u7684\u5185\u5bb9\uff0c\u5f97\u5230\u4e00\u4e2a\u65b0\u6587\u4ef6C.<\/h5>\n\n\n\n
          4.1\u5728scala\u6587\u4ef6\u5939\u4e0b\uff0c\u521b\u5efaHW10_2_Merge.scala\u6587\u4ef6\uff0c\u5728ch10_scala\u6587\u4ef6\u5939\u4e0b\u521b\u5efaHW10_2_Merge.sbt\u6587\u4ef6\uff0c\u521b\u5efa\u6587\u4ef6\u7684\u547d\u4ee4\u53ef\u53c2\u8003\u56fe5\uff1b\u5bf9\u4e8eHW10_2_Merge.scala\u6587\u4ef6\uff0c\u5185\u5bb9\u5982\u56fe11\u6240\u793a\uff0c\u5bf9\u4e8eHW10_2_Merge.sbt\u6587\u4ef6\uff0c\u5185\u5bb9\u5982\u56fe12\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe11<\/figcaption><\/figure>\n<\/div>\n\n
          \n
          \"\"
          \u56fe12<\/figcaption><\/figure>\n<\/div>\n\n\n
          4.2\u5220\u9664ch10_scala\u4e0b\u7684target\u548cproject\u6587\u4ef6\u5939\uff0c\u5220\u9664\u540e\u7684\u6587\u4ef6\u5939\u5185\u5bb9\u5982\u56fe13\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe13<\/figcaption><\/figure>\n<\/div>\n\n\n
          4.3\u5728hdfs\u4e0a\u5c06\u5b9e\u9a8c6\u7684\u4e24\u4e2a\u6570\u636e\u6e90\u590d\u5236\u5230ch10\/input_merge\u6587\u4ef6\u5939\u4e0b\uff0c\u7ed3\u679c\u5982\u56fe14\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe14<\/figcaption><\/figure>\n<\/div>\n\n\n
          4.4\u4f7f\u7528sbt package<\/code>\u547d\u4ee4\u6253\u5305\u540e\uff0c\u4f7f\u7528spark-submit --class \"HW10_2_Merge\" \/usr\/local\/spark\/sparkapps\/ch10_scala\/target\/scala-2.12\/hw10_2_merge_2.12-1.0.jar<\/code> \u547d\u4ee4\u5bf9hdfs\u4e2d\u7684\u591a\u6570\u636e\u6587\u4ef6\u8fdb\u884c\u5408\u5e76\u53bb\u91cd\uff0c\u5b8c\u6210\u540e\u901a\u8fc7cat\u547d\u4ee4\u89c2\u5bdf\u751f\u6210\u7684\u65b0\u6587\u4ef6\uff0c\u7ed3\u679c\u5982\u56fe15\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe15<\/figcaption><\/figure>\n<\/div>\n\n\n
          5.\u7f16\u5199\u72ec\u7acb\u5e94\u7528\u7a0b\u5e8f\u5b9e\u73b0\u6c42\u5e73\u5747\u503c\u95ee\u9898<\/h4>\n\n\n\n
          \u6bcf\u4e2a\u8f93\u5165\u6587\u4ef6\u8868\u793a\u73ed\u7ea7\u5b66\u751f\u67d0\u4e2a\u5b66\u79d1\u7684\u6210\u7ee9\uff0c\u6bcf\u884c\u5185\u5bb9\u7531\u4e24\u4e2a\u5b57\u6bb5\u7ec4\u6210\uff0c\u7b2c\u4e00\u4e2a\u662f\u5b66\u751f\u540d\u5b57\uff0c\u7b2c\u4e8c\u4e2a\u662f\u5b66\u751f\u7684\u6210\u7ee9\uff1b\u7f16\u5199Spark\u72ec\u7acb\u5e94\u7528\u7a0b\u5e8f\u6c42\u51fa\u6240\u6709\u5b66\u751f\u7684\u5e73\u5747\u6210\u7ee9\uff0c\u5e76\u8f93\u51fa\u5230\u4e00\u4e2a\u65b0\u6587\u4ef6\u4e2d\u3002<\/h5>\n\n\n\n
          5.1\u5728ch10_scala\u6587\u4ef6\u5939\u4e0b\u521b\u5efainput_avg\u6587\u4ef6\u5939\uff0c\u5728\u5176\u4e0b\u521b\u5efa\u4e09\u4e2a\u6587\u4ef6\uff08\u672c\u4f8b\u540d\u4e3aAlgorithm\/Database\/Python\uff0c\u6587\u4ef6\u5185\u5bb9\u53c2\u8003\u5982\u56fe16\u6240\u793a\uff0c\u5e76\u5c06\u8be5\u6587\u4ef6\u5939\u4e0a\u4f20\u5230hdfs\u7684ch10\u6587\u4ef6\u5939\u4e0b\uff0c\u547d\u4ee4\u5982\u56fe17\u6240\u793a\uff1b<\/p>\n\n\n
          \n
          \"\"
          \u56fe16<\/figcaption><\/figure>\n<\/div>\n\n
          \n
          \"\"
          \u56fe17<\/figcaption><\/figure>\n<\/div>\n\n\n
          5.2\u5728scala\u6587\u4ef6\u5939\u4e0b\uff0c\u521b\u5efaHW10_3_AvgScore.scala\u6587\u4ef6\uff0c\u5728ch10_scala\u6587\u4ef6\u5939\u4e0b\u521b\u5efaHW10_3_AvgScore.sbt\u6587\u4ef6\uff0c\u521b\u5efa\u6587\u4ef6\u7684\u547d\u4ee4\u53ef\u53c2\u8003\u56fe5\uff1b\u5bf9\u4e8eHW10_3_AvgScore.scala\u6587\u4ef6\uff0c\u5185\u5bb9\u5982\u56fe18\u6240\u793a\uff0c\u5bf9\u4e8eHW10_3_AvgScore.sbt\u6587\u4ef6\uff0c\u5185\u5bb9\u5982\u56fe19\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe18<\/figcaption><\/figure>\n<\/div>\n\n
          \n
          \"\"
          \u56fe19<\/figcaption><\/figure>\n<\/div>\n\n\n
          5.3\u5220\u9664ch10_scala\u4e0b\u7684target\u548cproject\u6587\u4ef6\u5939\uff0c\u5220\u9664\u540e\u7684\u5185\u5bb9\u5982\u56fe20\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe20<\/figcaption><\/figure>\n<\/div>\n\n\n
          5.4\u4f7f\u7528sbt package<\/code>\u547d\u4ee4\u6253\u5305\u540e\uff0c\u4f7f\u7528spark-submit --class \"HW10_3_AvgScore\" \/usr\/local\/spark\/sparkapps\/ch10_scala\/target\/scala-2.12\/hw10_3_avgscore_2.12-1.0.jar<\/code> \u547d\u4ee4\u5bf9hdfs\u4e2d\u7684\u591a\u6570\u636e\u6587\u4ef6\u8fdb\u884c\u5408\u5e76\u53bb\u91cd\uff0c\u5b8c\u6210\u540e\u901a\u8fc7cat\u547d\u4ee4\u89c2\u5bdf\u751f\u6210\u7684\u65b0\u6587\u4ef6\uff0c\u7ed3\u679c\u5982\u56fe21\u6240\u793a\u3002<\/p>\n\n\n
          \n
          \"\"
          \u56fe21<\/figcaption><\/figure>\n<\/div>","protected":false},"excerpt":{"rendered":"
          \u672c\u6587\u5206\u4e24\u4e2a\u90e8\u5206\uff0c\u7b2c\u4e00\u4e2a\u90e8\u5206\u4e3aSpark\u914d\u7f6e\u6559\u7a0b\uff08\u56e0\u4e3aXMU\u7684\u914d\u7f6e\u592a\u8001\u4e86\uff0c\u8fd9\u91cc\u6362\u4e86\u7248\u672c\uff0c\u5728\u8fd9\u91cc\u7b80\u5355\u8bb0\u5f55\u4e00\u4e0b\uff0c\u540c\u65f6 […]<\/p>\n","protected":false},"author":1,"featured_media":2305,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[33],"tags":[],"class_list":["post-2302","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-bdat"],"_links":{"self":[{"href":"https:\/\/www.leexinghai.com\/aic\/wp-json\/wp\/v2\/posts\/2302","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.leexinghai.com\/aic\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.leexinghai.com\/aic\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.leexinghai.com\/aic\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.leexinghai.com\/aic\/wp-json\/wp\/v2\/comments?post=2302"}],"version-history":[{"count":4,"href":"https:\/\/www.leexinghai.com\/aic\/wp-json\/wp\/v2\/posts\/2302\/revisions"}],"predecessor-version":[{"id":2347,"href":"https:\/\/www.leexinghai.com\/aic\/wp-json\/wp\/v2\/posts\/2302\/revisions\/2347"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.leexinghai.com\/aic\/wp-json\/wp\/v2\/media\/2305"}],"wp:attachment":[{"href":"https:\/\/www.leexinghai.com\/aic\/wp-json\/wp\/v2\/media?parent=2302"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.leexinghai.com\/aic\/wp-json\/wp\/v2\/categories?post=2302"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.leexinghai.com\/aic\/wp-json\/wp\/v2\/tags?post=2302"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}