Giraph 튜토리얼 ShortestPath 예제 작업 실패

아파치 Giraph 퀵 스타트 튜토리얼 : http://giraph.apache.org/quick_start.html을 통해 가상 분산 hadoop 클러스터를 성공적으로 설정하고 예제 mapreduce 작업을 성공적으로 실행했습니다.Giraph 튜토리얼 ShortestPath 예제 작업 실패

하지만 Giraph 섹션으로 이동할 때 Giaven을 사용하여 Giaven을 설치했는데 어떤 이유로 Giraph 작업이 가장 간단하지 않습니다.

나는 나의 HDFS에 tiny_graph을 추가하지만, 자신의 예를 들어 명령을 실행했습니다

[email protected]:~/Giraph$ $HADOOP_HOME/bin/hadoop jar /usr/local/giraph/giraph-examples/target/giraph-examples-1.2.0-SNAPSHOT-for-hadoop-1.2.1-jar-with-dependencies.jar org.apache.giraph.GiraphRunner org.apache.giraph.examples.SimpleShortestPathsComputation -vif org.apache.giraph.io.formats.JsonLongDoubleFloatDoubleVertexInputFormat -vip /user/hduser/input/tiny_graph.txt -vof org.apache.giraph.io.formats.IdWithValueTextOutputFormat -op /user/hduser/output/shortestpaths -w 1

나에게 제공합니다 :

14/12/18 11:19:27 INFO utils.ConfigurationUtils: No edge input format specified. Ensure your InputFormat does not require one. 
14/12/18 11:19:27 INFO utils.ConfigurationUtils: No edge output format specified. Ensure your OutputFormat does not require one. 
14/12/18 11:19:28 INFO job.GiraphJob: run: Since checkpointing is disabled (default), do not allow any task retries (setting mapred.map.max.attempts = 1, old value = 4) 
14/12/18 11:19:31 INFO job.GiraphJob: Tracking URL: http://hdnode01:50030/jobdetails.jsp?jobid=job_201412171202_0010 
14/12/18 11:19:31 INFO job.GiraphJob: Waiting for resources... Job will start only when it gets all 2 mappers 
14/12/18 11:20:59 INFO job.HaltApplicationUtils$DefaultHaltInstructionsWriter: writeHaltInstructions: To halt after next superstep execute: 'bin/halt-application --zkServer fonz-virtualbox:22181 --zkNode /_hadoopBsp/job_201412171202_0010/_haltComputation' 
14/12/18 11:20:59 INFO mapred.JobClient: Running job: job_201412171202_0010 
14/12/18 11:21:00 INFO mapred.JobClient: map 100% reduce 0% 
14/12/18 11:30:16 INFO mapred.JobClient: map 50% reduce 0% 
14/12/18 11:30:24 INFO mapred.JobClient: Job complete: job_201412171202_0010 
14/12/18 11:30:24 INFO mapred.JobClient: Counters: 6 
14/12/18 11:30:24 INFO mapred.JobClient: Job Counters 
14/12/18 11:30:24 INFO mapred.JobClient:  SLOTS_MILLIS_MAPS=1244789 
14/12/18 11:30:24 INFO mapred.JobClient:  Total time spent by all reduces waiting after reserving slots (ms)=0 
14/12/18 11:30:24 INFO mapred.JobClient:  Total time spent by all maps waiting after reserving slots (ms)=0 
14/12/18 11:30:24 INFO mapred.JobClient:  Launched map tasks=2 
14/12/18 11:30:24 INFO mapred.JobClient:  SLOTS_MILLIS_REDUCES=0 
14/12/18 11:30:24 INFO mapred.JobClient:  Failed map tasks=1

어떤 아이디어이 크게 감상 할 수있다 실패 이유에!

대단히 감사합니다.

는

출처

2014-12-18 WillJones

최단 경로의 예는 주요 방법이없는 것이며, 그 알고리즘을 시작하기 위해, 1로 하드 코딩 된 소스 ID를 사용한다. 따라서 100 %지도 이후에 투표를 중단 할 투표가 없습니다. https://www.youtube.com/watch?v=yEHeJhMXJy0으로 이동하여 sssp.java 파일을 업데이트하고 새 Jar 파일로 내 보냅니다. 그런 다음 실행하십시오. 나는 같은 문제에 직면했고 그것을 고쳤다.

출처

2014-12-23 03:16:13

안녕하세요. Rishabh, 응답과 링크에 감사드립니다. 비디오가 요약 한 내용, 즉 다음 주석의 코드를 SimpleShortestPathsVertex.java 파일에 추가 한 다음 모든 것을 다시 빌드했지만 여전히 동일한 오류가 발생합니다! – WillJones

공용 클래스 SimpleShortestPathsComputation이 BasicComputation를 확장 < LongWritable, DoubleWritable, FloatWritable, DoubleWritable> { ** 개인 정적 오래 startVertexId을; public static void main (String [] args) { startVertexId = Long.valueOf (args [0]); } ** /** 최단 경로 ID */ 공공 정적 최종 LongConfOption SOURCE_ID = 새로운 LongConfOption ("SimpleShortestPathsVertex.sourceId"startVertexId ** ** "최단 경로 ID"); /** 클래스 로거 */ private static final Logger LOG = Logger.getLogger (SimpleShortestPathsComputation.class); – WillJones

Giraph 코드를 실행하기 위해 툴 러너를 사용해야한다고 생각합니다. 그러나 이것은 또한 작동해야합니다. main 메소드를 구현 한 후에도 시스템이 여전히 정지 상태입니까? –

Giraph 튜토리얼 ShortestPath 예제 작업 실패

답변

관련 문제