我有两份hadoop工作。第一个作业将输出保存在hdfs文件中,第二个作业将此文件作为输入。当这个文件不存在时,我有一个错误。如果第一个作业outfile不存在,如何跳过第二个作业?
csga3l581#
使用此测试,但使用第一个作业创建的路径:
FileSystem fs = FileSystem.get(conf); String inputDir= "HDFS file path"; if (fs.exists(new Path(inputDir))) { // this block gets executed only if the file path inputDir exists }
块中的代码将包含第二个作业的配置和执行代码。
1条答案
按热度按时间csga3l581#
使用此测试,但使用第一个作业创建的路径:
块中的代码将包含第二个作业的配置和执行代码。