áá¬áá áááºá¹ááá¬áá«á ááá±á·á
Spark ááá¯á¡áá¯á¶ážááŒá¯áá¯á¶á¡ááŒá±á¬ááºáž á¡áááºážáááºááááºáááºáá±ážáá«áá
á±á áá»áœááºáá±á¬áºááá¯á·ááŸá¬ áá¯á¶ážáá¡á
á®á¡á
ááºááŸááááºá
áá»áœááºá¯ááºááá¯á·áá¡áá¯á¶ážááŒá¯ááŸá¯ááá°ážááŒá¬ážáá»ááºááŸá¬ Spark ááá¯áá áºááŒáá¯ááºáááºáááºážáá¯ááºáá±á¬ááºáá±áá±á¬áá°á¡áá±á¡ááœááºáááºáá áºááœá²á·áá¯á¶ážááŸáá·áºáá°áá®ááá¯ááºáááºá á¥ááá¬á¡á¬ážááŒáá·áºá ááœá±ážááœá±ážááœá²áá áºáá¯ááŸá¬ áá°ááá¯ááºážá áá áºáá»áááºáááºážááŸá¬ áá áºáá¯áá¯ááŒáá¯ážá á¬ážááŒá®áž áá«ááá¯á·áá²á·ááá¬áá±á¬ááºááŸá¬ áááºááŒá±á¬áá²á·á¡áá«á áá«áá¡áá»á¬ážááŒá®ážááá¯ááºáá«áá°áž - áá áºáá«áá áºáá¶áá° 40 á¡ááá ááá¹áá¬áá±á«áºááœáẠááá¯ááá¯á·áá±á¬á¡áá¯á¶ážááŒá¯ááŸá¯ááá á¹á ááŸáá·áº áááºááá¯ááºáá±ááá±á¬ áá¯áá¹ááá®áá»á¬ážá áœá¬ áááŸááá«á
ááá¯á·áá±á¬ááºá áá»áœááºá¯ááºááá¯á·ááẠá¡áá»áá¯á·áá±á¬ config parameters áá»á¬ážááᯠáááºááá¯á·ááœá±ážáá»ááºáá²á·áááºááᯠááŒá±á¬ááŒáá«áááºá
á¡á ááá± á ááá¯ááºáá¡á±á¬ááºá Spark ááœáẠá¡á á¯á¡áá±ážáá áºáá¯áá±á«áºááœáẠáá¯ááºáá±á¬ááºááẠááœá±ážáá»ááºá áᬠ3 áᯠááŸááááº- áá®ážááá·áºá Mesos ááá¯á¡áá¯á¶ážááŒá¯ááŒááºážááŸáá·áº YARN ááá¯á¡áá¯á¶ážááŒá¯ááŒááºážá áá»áœááºá¯ááºááá¯á·á¡ááœáẠá¡áááá¹áá«ááºááŸááá±á¬ááŒá±á¬áá·áº ááááááœá±ážáá»ááºááŸá¯ááᯠááœá±ážáá»ááºááẠáá¯á¶ážááŒááºáá²á·áááºá áá»áœááºá¯ááºááá¯á·ááœáẠhadoop á¡á á¯á¡áá±ážáá áºáᯠááŸáááŸáá·áºááŒá®ážááŒá áºáááºá áá»áœááºá¯ááºááá¯á·ááá«áááºáá°áá»á¬ážááẠáááºážááááá¯áá¬ááá¬ááᯠáá±á¬ááºážá áœá¬ááááŒá®ážááŒá áºáááºá YARN áá¯á¶ážááŒáá·áºáá¡á±á¬ááºá
spark.master=yarn
ááá¯á
áááºáááºá
á¬ážááá¯á·áá±á¬ááºážáááºá ဠá¡áá¯á¶ážáá»ááŸá¯ ááœá±ážáá»ááºá
áᬠ3 áᯠáá
áºáá¯á
á®ááœáẠá¡áá¯á¶ážáá»ááŸá¯ ááœá±ážáá»ááºá
áᬠ2 áᯠááŸááááº- client ááŸáá·áº cluster á á¡ááŒá±áá¶
spark.deploy-mode=client
áá±áá¯áá»á¡á¬ážááŒáá·áºá ááá¯ááŸá ááŒá®áž Spark ááẠYARN ááœáẠáá áºáááºážáááºážááŒáá·áº áá¯ááºáá±á¬ááºááá¯ááºáá±á¬áºáááºáž áááºážááẠáá»áœááºá¯ááºááá¯á·á¡ááœáẠááá¯á¶áá±á¬ááºáá«á áá»áœááºá¯ááºááá¯á·ááœáẠáá±áá¬ááŒá®ážááŒá®ážáá¬ážáá¬ážááŸáá·áºáááºáááºááá·áº áááá¯ááááºáá áºáá¯ááŸááá±á¬ááŒá±á¬áá·áº áá áºáá«áá áºáá¶ááœáẠáá«áááºáá°áá»á¬ážááẠá¡áááºážá¡ááŒá áºáá»á¬ážááᯠááá¯ááºážááŒááºááŒááºážááá±á¬ááºá¡ááœááºážá áááŸááá±á¬á¡áá¬áá»á¬ážááᯠáá¯á¶áá±á¬ááºá áœá¬ááááŸáááŒáá«á ááŒá®ážáá±á¬á· á áááºáááºá á¬ážá áá¬áá±á¬ááºážáá²á·á¡áá»áẠ- áááºááŒáœáá²á·á¡áááºážá¡ááŒá áºááœá²áá±ááŸá¯á á¡ááá¯áá»á¯ááºááŒá±á¬ááá»áŸáẠá¡áá»ááºááŸá¬ á€á¡áá¬ááŒá áºáááº- á¡áááºá ááá·áºááœáẠáááºáá²áá±á¬á¡áá¯ááºáá áºáá¯ááŸáááŒá®áž á¡á á¯á¡ááœá²á·ááẠá¡ááá²á·ááŒá áºááẠ(á¥ááá¬á áá¶áááºááá¯ááºáž)á ááá¯á·áá±á¬áẠá€ááœá±ážáá»ááºááŸá¯ááᯠSpark ááá¯á¡áá¯á¶ážááŒá¯ááŒááºážááŒáá·áº ááá·áºá¡á¬áž áá±á¬ááºáááºá¡áááºážá¡ááŒá áºáá»á¬ážááᯠáá±ážááá¯ááºáá«áááºá ááá¯á¡ááºáá»ááºáá»á¬ážááᯠáá±á¬ááºáá»á áºáá±á¬ áá¯á¶áá±áááºážá¡á ááœááºáá»ááºáááºá á¡áá±ážá áááºá¡áá»ááºá¡áááºáá»á¬ážááá¯áá»áœááºá¯ááºááá¯á·ááá±á·áá¬áá« - áááºážáááºáá±á¬ááºážá áœá¬á¡áá¯ááºáá¯ááºáááºá
spark.dynamicAllocation.enabled=true
áá»áœááºá¯ááºááá¯á·ááẠá€áááºááŸááºáá»ááºááᯠáááºááŸááºááŒá®áž á
áááºáá»áááºááœáẠSpark áá»ááºááœá¬ážááŒá®áž áá
áááºáá«á ááŸááºááẠááá¯áá±á¬á· áá»áœááºáá±á¬áº áááºáá²á·ááááºá
spark.shuffle.service.enabled=true
áá¬ááŒá±á¬áá·áº ááá¯á¡ááºáá¬áá²á áá»áœááºá¯ááºááá¯á·áá¡áá¯ááºááẠá¡áááºážá¡ááŒá áºáá»á¬ážá áœá¬áááá¯á¡ááºáá±á¬á·ááá·áºá¡áá« Spark ááẠáááºážááá¯á·ááᯠáá¯á¶áá±áááºááá¯á· ááŒááºáá±ážááá·áºáááºá MapReduce áá¯ááºá áá¬á¡á¬ážáá¯á¶ážáá®ážáá«ážááœáẠá¡áá»áááºáá¯ááºáá¯á¶ážá¡ááá·áºááŸá¬ ááŒá°ážááŒáœááá·áºá¡ááá·áºááŒá áºáááºá á€á¡ááá·áºáááºááŸááºáá»ááºááẠááá·áºá¡á¬áž á€á¡ááá·áºááœáẠáá¯ááºáá±ážááá·áºáá±áá¬ááᯠááááºážáááºážááá¯ááºááŒá®áž á á®áá¶á¡á¯ááºáá»á¯ááºáá°áá»á¬ážááᯠáá»á±á¬áºáá®á áœá¬ áá¯ááºááŒááºááá¯ááºá á±áááºááŒá áºáááºá ááŒá®ážáá±á¬á· executor á á¡áá¯ááºááá¬ážá¡áá±á«áº á¡áá¬á¡á¬ážáá¯á¶ážááᯠááœááºáá»ááºáá±ážáá²á· áá¯ááºáááºážá ááºáá«á áááºážááœáẠá¡áá»áá¯á·áá±á¬ áááá¯áááºáᬠCore á¡áá±á¡ááœááºááŸáá·áº ááŸááºáá¬ááºááá¬áá¡áá»áá¯á· ááŸááááºá
á€áááºááŸááºáá»ááºááᯠááá·áºááœááºážááŒá®ážááŒá áºáááºá á¡áá¬á¡á¬ážáá¯á¶ážá á¡áá¯ááºááŒá áºáá¯á¶ááááºá áá«áááºáá°áá»á¬ážááẠáááºážááá¯á·ááᯠááá¯á¡ááºáá±á¬á¡áá«ááœáẠá¡áááºážá¡ááŒá áºáá»á¬áž ááá¯ááá¯áá±ážá¡ááºáá²á·ááŒá±á¬ááºáž áááá¬áááºááŸá¬ážáá¬áááºá ááá¯á·áá±á¬áº á¡ááŒá¬ážááŒá¿áá¬áá áºáᯠáá±á«áºáá¬áááº- áá áºáá»áááºáá»áááºááœáẠá¡ááŒá¬ážáá«áááºáá°áá»á¬áž ááá¯ážáá¬ááŒá®áž Spark ááᯠá¡áá¯á¶ážááŒá¯ááá¯áá±á¬áºáááºáž ááá¯áá±áá¬ááœáẠá¡áá¬á¡á¬ážáá¯á¶áž á¡áá¯ááºááŸá¯ááºáá±ááŒá®áž áááºážááá¯á·ááẠááá»á±á¬áºáááœáŸáẠááŒá áºáá±ááŒáááºá áá°ááá¯á·áá¬ážáááºááá¯ááºáááºá á á¬ááœááºá á¬áááºážááœá±ááᯠá áááºááŒáá·áºááŸá¯áá²á·ááŒáááºá áá¯ááºáááºážá ááºááᯠááœáŸááºážááá¯ážááẠá¡áá¯á¶ážááŒá¯ááá¯ááºááá·áº á¡ááŒá¬ážáá±á¬ ááá·áºáááºáá»ááºáá»á¬áž áá»á¬ážá áœá¬ááŸááá±ááŒá±á¬ááºáž ááœá±á·ááŸáááá«áááºá á¥ááá¬á¡á¬ážááŒáá·áºá executor ááẠstandby mode ááœááºááŸááá±áá«áá á¡áááºážá¡ááŒá áºáá»á¬ážááá¯áááºááá·áºá¡áá»áááºááŸáá¯ááºáá°ááá¯ááºáááºáááºážá
spark.dynamicAllocation.executorIdleTimeout=120s
áá»áœááºá¯ááºááá¯á·áá¡ááŒá±á¡áá±ááœááºá áááºáááá¬ážá á®áááºáá±ážááŸá°ážáá»á¬ážááẠááŸá áºáááá áºááŒá¬á¡á±á¬áẠáá¬ááŸááá¯ááºáá«áá áááºážááá¯á·ááᯠáá¯á¶áá±áááºááá¯á· ááŒááºááá¯á·áá±ážáá«á áá«áá±ááá·áº áá®áááºááŸááºáá»ááºá á¡ááŒá²áááºáž ááá¯á¶áá±á¬ááºáá«áá°ážá ááá¯áá°ááẠá¡áá»áááºá¡áá±á¬áºááŒá¬á¡á±á¬áẠáá¬ááŸááá¯ááºáá²á á¡áááºážá¡ááŒá áºáá»á¬áž áááœááºááŒá±á¬ááºááŒá±á¬ááºáž áááºááŸá¬ážáá«áááºá áááºááŸáºáá±áá¬áá«ááŸááá±á¬ executors ááá¯ááœá±ážáá»ááºááẠáááºááá·áºá¡áá»áááºááŒá®ážáá±á¬ááºááœáẠá¡áá°ážááá·áºáááºáá±á¬ááºáá áºáá¯áááºáž ááŸááá±ááŒá±á¬ááºáž ááœá±á·ááŸáááá«áááºá áá°áááºážá¡á¬ážááŒáá·áºá á€ááá·áºáááºáá»ááºááẠá¡áá¯á¶ážáááŸáááŒá áºáááºá á¡á²áá«ááᯠáá»áœááºáá±á¬áºááá¯á· ááŒááºáááºá
spark.dynamicAllocation.cachedExecutorIdleTimeout=600s
ááá¯ááá¯áááºááŸá¬á áááºáááá¬ážá á®áááºáá±ážááŸá°ážáá»á¬ážááẠá áááá áºááŒá¬áá»áŸ áá¬ááŸááá¯ááºáá«áá áááºážááá¯á·ááᯠáá¯á¶áá±áááºááá¯á· áá±ážááá¯ááºáá«á á€áá¯ááºááœááºá á¡áá¯á¶ážááŒá¯áá°á¡áá»á¬ážá¡ááŒá¬ážá¡ááœáẠá¡áááºážá¡ááŒá áºáá»á¬ážááᯠáá¯ááºááœáŸááºááŒááºážááŸáá·áº áá¯ááºáá±ážááŒááºážá á¡ááŒááºááŸá¯ááºážááẠááá·áºááá·áºáá»á±á¬ááºáááºáááºá ááá»á±ááááºááŒá áºááŸá¯ ááá¬á áá»á±á¬á·ááœá¬ážáá«ááŒá®á ááá¯á·áá±á¬áº áá»áœááºá¯ááºááá¯á·ááẠáááºááá·áºááœá¬ážááẠáá¯á¶ážááŒááºááŒá®áž áá»áŸá±á¬ááºááœáŸá¬áá áºáá¯áá»áŸáẠá¡áá»á¬ážáá¯á¶áž á á®áá¶á¡á¯ááºáá»á¯ááºáá° á¡áá±á¡ááœááºááᯠááá·áºáááºááẠáá¯á¶ážááŒááºáá²á·ááẠ- á¡ááŒá±áá¶á¡á¬ážááŒáá·áº áááá¯ááááºáá«áááºáá° áá áºáŠážá á®á¡ááœáẠááŒá áºáááºá
spark.dynamicAllocation.maxExecutors=19
á¡áá¯á áá áºáááºááŸá¬ ááá»á±áááºáá²á·áá°ááœá±ááŸáááẠ- "á¡á á¯á¡áá±ážá áá¬ááŸááá¯ááºáá²á áá«á·ááŸá¬ á¡ááŸá¯á á®áááºáá° áá áá±á¬ááºáá²ááŸááááº" áá«áá±ááá·áº áááºážáá¬áá¯ááºááá¯ááºááá²á ááŸááºáááºáá²á· áá»áááºááœááºáá»áŸá¬áá»áá¯ážááá¯áááºá áá°ááá¯ááºážááᯠáá»á±á¬áºááœáŸááºá¡á±á¬áẠááá¯ááºááá¯ááºáá«áá°ážá
áá»áœááºá¯ááºááá¯á·áááŒá áºáááºááŸáá·áºáááºáááºáá±á¬ áá±á¬ááºáááºá¡áá±ážá áááºá¡ááŒá±á¬ááºážá¡áá¬áá áºáá¯á áá áºáááºážáá áºáá¯á¶á¡á¬ážááŒáá·áº áá°áá»á¬ážá áœá¬ááẠáááºááœá±á·áááºáááºážá á¬á¡ááœáẠáá±á¬ááºáá»áá²á·ááŒááŒá®áž á¡ááŒá±á¬ááºážáá áºáá¯áá¯ááŒá±á¬áá·áº Spark ááẠáááºážááá¯á·á¡ááœáẠáá áááºáá²á·áá±á á¡ááá²á·á¡áááºážá¡ááŒá áºáá»á¬áž ááá¬áááᯠáá»áœááºá¯ááºááá¯á·ááŒáá·áºááŸá¯áá²á·áááº- ááá¯áá±áá¬ááœáẠááŸááá±áá¯á¶ááááºá áá®ážááœá¬ážá áááºááá·áºáááºá áá¶áá±á¬ááºážáá±á¬ááºáá áœá¬á ááá¯á¡áá»áááºááœáẠá á¬ááœááºá á¬áááºážáá»á¬ážááᯠáá áºáá±áá¬áá¬ááá¯á· subcortex ááœááºááá·áºááœááºážáá¬ážááŒá®ážááŒá áºááŒá®áž á áááºááá·áºá¡áá« Spark ááẠá áááºááá·áº port ááá¯ááŸá¬ááœá±áá±ááŒá±á¬ááºáž áá»áœááºá¯ááºááá¯á·áááááááááºá á¡ááœá¬á¡áá±ážááŸá ááá port ááẠá¡áá¯ááºáá»á¬ážáá±áá«áá áááºážááẠá¡á ááºááá¯ááºá¡ááá¯ááºáž áá±á¬ááºáá áºáá¯ááá¯á· ááœáŸá±á·áááºá á¡ááá¬ážáááẠáááºážáááºá ááŒá®ážáá±á¬á· áá®á¡ááœáẠá¡áá»á¬ážáá¯á¶áž ááŒáá¯ážá á¬ážááŸá¯ á¡áá±á¡ááœááºááᯠááœáŸááºááŒáá²á· ááá·áºáááºáá»ááºáá áºáᯠááŸááá«áááºá áá°áááºážááŸá¬ 16 ááŒá áºáááºá áá¶áá«ááºááẠá¡áááºážááŸá áá»áœááºá¯ááºááá¯á·áá¡ááœá²á·ááŸá áá°á¡áá±á¡ááœááºááẠáááºážáá«áááºá ááá¯á·ááŒá±á¬áá·áºá 16 ááŒáááºááŒáá¯ážá á¬ážááŒá®ážáá±á¬áẠSpark áááºáááºáá»áŸá±á¬á·ááŒá®áž áá»áœááºá¯ááºáá áááºááá¯ááºáá±á¬á·ááŒá±á¬ááºážááŒá±á¬áá²á·áááºá áá»áœááºá¯ááºááá¯á·ááẠá€ááá·áºáááºáá»ááºááᯠááŒá¯ááŒááºááŒá®ážááŒá áºáááºá
spark.port.maxRetries=50
ááá¯á·áá±á¬áẠáá»áœááºá¯ááºááá¯á·áááá á¹á áááºááŸáá·áº á¡ááœááºáááºááá¯ááºááŒááºážáááŸááá±á¬ á¡áá»áá¯á·áá±á¬áááºáááºáá»á¬ážá¡ááŒá±á¬ááºáž ááŒá±á¬ááŒáá«áááºá
Spark ááá¯ááá¯ááá¯ááŒááºáááºá áœá¬á áááºáááºá SPARK_HOME áááºááááºážááœáŸááºááœááºááŸááá±á¬ jars ááá¯ááºááœá²ááá¯ááááºážáááºážááŒá®áž HDFS ááœááºááá·áºáááºá¡ááŒá¶ááŒá¯áá¬ážáááºá á¡á²áá®á¡áá«ááŸá¬ á¡áá¯ááºááá¬ážááœá±á áá® jarnik ááœá±áááºáᬠá¡áá»áááºááŒá¯ááºážááŸá¬ááá¯ááºáá°ážá
spark.yarn.archive=hdfs:///tmp/spark-archive.zip
ááá¯ááá¯ááŒááºáááºáá±á¬áá¯ááºáá±á¬ááºáá»ááºá¡ááœáẠkryo ááᯠáá¶áá«ááºá ááºá¡ááá¯ááºá¡áá¯á¶ážááŒá¯áááºáááºáž á¡ááŒá¶ááŒá¯áá¬ážáááºá áááºážááẠáá°áááºážáá¯á¶á á¶ááẠááá¯áá±á¬ááºážá¡á±á¬ááºááŒá¯áá¯ááºáá¬ážáááºá
spark.serializer=org.apache.spark.serializer.KryoSerializer
ááá¯á·á¡ááŒáẠáááºážááẠááŸááºáá¬ááºá០áááŒá¬áá áá»ááºá á®ážááœá¬ážááá·áº Spark ááœáẠááŒá¬ááŸááºá áœá¬ ááŒá¿áá¬áá áºáá¯áááºáž ááŸááá«áááºá á¡áá¯ááºááá¬ážáá»á¬ážááẠá¡áá¬á¡á¬ážáá¯á¶ážááᯠááœááºáá»ááºááŒá®áž ááááºááᯠáá¬ááºáá±á¬ááºážáᶠáá±ážááá¯á·áá±á¬á¡áá«ááœáẠá€á¡áá¬ááẠáááŒá¬áá ááŒá áºááœá¬ážáááºáá«áááºá áá»áœááºá¯ááºááá¯á·ááẠá€ááá·áºáááºáá»ááºááᯠááá¯ááŒá®ážá¡á±á¬áẠááŒá¯áá¯ááºáá¬ážáááºá áá¯á¶ááŸááºá¡á¬ážááŒáá·áºá áááºážááẠ1GB ááŒá áºááŒá®ážá áá»áœááºá¯ááºááá¯á·ááẠáááºážááᯠá áá¯ááŒá¯áá¯ááºáá¬ážáááºá
spark.driver.maxResultSize=3072
áá±á¬ááºáá¯á¶ážá¡áá±áá²á· á¡áá»áá¯ááœá²á¡ááŒá áºá HortonWorks ááŒáá·áºááŒá°ážááŸá¯ááœáẠSpark ááᯠáá¬ážááŸááºáž 2.1 ááá¯á· á¡ááºááááºáá¯ááºáááºáž - HDP 2.5.3.0á HDP áá€áá¬ážááŸááºážááœáẠááŒáá¯áááºááá·áºááœááºážáá¬ážáá±á¬áá¬ážááŸááºáž 2.0 áá«ááŸááááºá ááá¯á·áá±á¬áº Spark ááẠá¡ááœááºáááºááŒáœá áœá¬áá¯ááºáá±á¬ááºáá±ááŒá®ááŒá áºááŒá±á¬ááºáž áá»áœááºá¯ááºááá¯á·ááá¯ááºááá¯ááºáá¯á¶ážááŒááºááŒá®ážáááºááŸáá·áº áá¬ážááŸááºážá¡áá áºáá áºáá¯á á®ááẠáá»áá¯á·ááœááºážáá»ááºá¡áá»áá¯á·ááᯠááŒááºáááºááŒá®áž python API á¡ááœáẠá¡áá«á¡ááẠáá±á¬ááºáááºá¡ááºá¹áá«áááºáá»á¬ážááᯠáá¶á·ááá¯ážáá±ážáá±á¬ááŒá±á¬áá·áº áá»áœááºá¯ááºááá¯á· áá¯á¶ážááŒááºáá²á·áááºá á¡áááºá¡áá¬ááá¯á¡ááºááááºážá ááŒá®ážááœá¬ážáááºá update áá áºáá¯ááŒá áºáááºá
Hadoop 2.7 á¡ááœááºááá¬ážáááºáááºááá¯ááºááŸáá¬ážááŸááºážááá¯áá±á«ááºážáá¯ááºáá¯ááºáá²á·áááºá áá áºááœáá·áºááŒá®áž HDP ááá¯áá«ááœáẠááá·áºáá«á áá»áœááºá¯ááºááá¯á·ááẠááá¯á¡ááºáááᯠsymlinks áá»á¬ážááᯠááá·áºááœááºážáá¬ážáá«áááºá áá»áœááºá¯ááºááá¯á· á áááºááá¯ááºááẠ- áá áááºáá«á á¡ááœááºáá°ážáááºážáá²á· á¡ááŸá¬ážáá áºáá¯áá±ážáááºá
java.lang.NoClassDefFoundError: com/sun/jersey/api/client/config/ClientConfig
Googling áá¯ááºááŒá®ážáá±á¬áẠSpark ááẠHadoop áááœá±ážááœá¬ážáá®á¡áá áá
á±á¬áá·áºááẠáá¯á¶ážááŒááºáá²á·ááŒá®áž áá»á¬á
á®áá¬ážááŸááºážá¡áá
áºááᯠá¡áá¯á¶ážááŒá¯ááẠáá¯á¶ážááŒááºáá²á·áááºá JIRA ááœáẠá€á¡ááŒá±á¬ááºážá¡áá¬ááŸáá·áºáááºáááºá áááºážááá¯á·ááá¯ááºááá¯áẠá¡áá»ááºážáá»ááºáž ááŒááºážáá¯á¶ááŒáááºá ááŒá±ááŸááºážáááºážááá±á¬á· áá±á«ááºážáá¯ááºáá¯ááºáá«á
áá»áœááºá¯ááºááá¯á·ááẠá€á¡ááŸá¬ážááᯠááŒá¯á¶ááœá±á·áá²á·ááá±á¬áºáááºážá ááá¯ááá¯áá±á¬ááºážááœááºááŒá®áž ááá¯ážááŸááºážáá±á¬ á¡áá áºáá áºáᯠáá±á«áºáá¬áá«áááºá
org.apache.spark.SparkException: Yarn application has already ended! It might have been killed or unable to launch application master
áá áºáá»áááºáááºážááŸá¬áááºá áá»áœááºá¯ááºááá¯á·áááºáá¬ážááŸááºáž 2.0 ááᯠrun áááºááŒáá¯ážá á¬ážááẠ- á¡á¬ážáá¯á¶ážá¡áááºááŒá±áááºá áá¬ááŒá áºáá±áá¬áá² ááá·áºááŸááºážááŒáá·áºáá«á áá»áœááºá¯ááºááá¯á·ááẠá€á¡ááá®áá±ážááŸááºážá ááŸááºáááºážáá»á¬ážááᯠááŒáá·áºááŸá¯ááŒá®áž á€áá²á·ááá¯á· á¡áá¬áá áºáá¯ááᯠááœá±á·ááá¯ááºááááº-
/usr/hdp/${hdp.version}/hadoop/lib/hadoop-lzo-0.6.0.${hdp.version}.jar
áá±áá¯áá»á¡á¬ážááŒáá·áºá á¡ááŒá±á¬ááºážáá áºáá¯áá¯ááŒá±á¬áá·áº hdp.version ááẠáááŒá±áááºáá²á·áá«á Googling áá¯ááºááŒá®ážáá±á¬áẠáá»áœááºá¯ááºááá¯á·ááẠá¡ááŒá±áá áºáá¯ááᯠááœá±á·ááŸááá²á·áááºá áááºááẠAmbari ááŸá YARN áááºáááºáá»á¬ážááá¯á·ááœá¬ážááŒá®áž á áááºááŒáá¯áẠyarn-site ááá¯á· ááá·áºáááºáá»ááºáá áºáá¯ááᯠáá±á«ááºážááá·áºááẠááá¯á¡ááºáááº-
hdp.version=2.5.3.0-37
áá®ááŸá±á¬áºááá¬á áá°áá®áá±ážáá²á·ááŒá®áž Spark á ááœááºááœá¬ážáááºá áá»áœááºá¯ááºááá¯á·ááẠáá»áœááºá¯ááºááá¯á·á Jupyter áááºááºáá±á¬á·áá»á¬ážá áœá¬ááᯠá ááºážáááºáá²á·áááºá á¡á¬ážáá¯á¶ážá á¡áá¯ááºáá¯ááºáá«áááºá á áá±áá±á· (ááááºááŒááº) ááœáẠááááá¯á¶áž Spark áááºáááºážá á¬á¡ááœáẠáá»áœááºá¯ááºááá¯á· á¡ááá·áºááŒá áºáá±áá«ááŒá®á
DUP. á á¬áááºáá»áááºá¡ááœááºáž áá±á¬ááºáááºááŒá¿áá¬áá áºáᯠáá±á«áºáá¬áááºá áá áºáá»áááºáá»áááºááœááºá YARN ááẠSpark á¡ááœáẠááœááºááááºáá¬áá»á¬áž áá±ážáá±á¬ááºááŒááºážááᯠáááºááá¯ááºáááºá YARN ááœáẠdefault á¡á¬ážááŒáá·áº 0.2 ááŒá áºááá·áº parameter ááᯠááŒááºáááºááá¯á¡ááºáá«áááºá
yarn.scheduler.capacity.maximum-am-resource-percent=0.8
ááá¯ááá¯áááºááŸá¬ áááºážááŒá
áºáá»á¬ážá 20% áá»áŸáᬠá¡áááºážá¡ááŒá
áºáá»á¬áž ááŒáá·áºááŒá°ážáá¬ááœáẠáá«áááºáá²á·áááºá ááá·áºáááºáá»ááºáá»á¬ážááᯠááŒá±á¬ááºážáá²ááŒá®ážáá±á¬ááºá áá»áœááºá¯ááºááá¯á·ááẠYARN ááᯠááŒááºáááºá
áááºáá²á·áááºá ááŒá¿áá¬ááᯠááŒá±ááŸááºážááŒá®áž áá»ááºáá«áááºáá°áá»á¬ážááááºáž áá®ážááœá¬ážá¡ááŒá±á¬ááºážá¡áá¬ááᯠáá¯ááºáá±á¬ááºááá¯ááºáá²á·áááºá
source: www.habr.com