使用Python 2.7 subprocess.Popen执行Sqoop命令时遇Accumulo警告终止问题

这问题我之前处理过！你猜的没错——核心原因是Sqoop输出的Accumulo警告触发了非零的退出状态码，而subprocess.Popen默认会严格返回这个状态码，导致你误以为进程没执行完；但Linux终端里shell会忽略这类非致命的警告状态，所以能顺利跑完整个传输流程。

下面给你几个可行的解决方案：

1. 重定向stderr到stdout或直接丢弃警告 #

把Sqoop的错误输出（包括警告）和标准输出合并，或者直接丢弃，这样警告不会单独触发错误状态：

# 合并stdout和stderr，方便后续查看警告内容
process = subprocess.Popen(sqoop_cmd, stdout=subprocess.PIPE, stderr=subprocess.STDOUT)

# 或者直接丢弃stderr（如果不需要看警告的话）
process = subprocess.Popen(sqoop_cmd, stdout=subprocess.PIPE, stderr=subprocess.DEVNULL)

2. 使用communicate()等待进程完成并判断输出 #

poll()只是检查进程的当前状态，可能会在进程还在处理时就返回状态码。改用communicate()可以等待进程完全执行完毕，再根据返回码和输出内容区分是真错误还是警告：

process = subprocess.Popen(sqoop_cmd, stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
output, _ = process.communicate()
return_code = process.returncode

if return_code != 0:
    # 检查输出里是否包含Accumulo警告关键词
    if "Accumulo" in output:
        print("Sqoop遇到Accumulo警告，但表传输已完成")
    else:
        print(f"Sqoop执行失败，错误信息：{output}")
else:
    print("Sqoop表传输成功")

3. 模拟终端shell执行（应急方案） #

如果你的Sqoop命令是完整字符串形式，可以加上shell=True参数，让subprocess模拟终端的执行环境，这样和你手动在终端跑的行为更一致：

process = subprocess.Popen(sqoop_cmd, stdout=subprocess.PIPE, stderr=subprocess.STDOUT, shell=True)

⚠️ 注意：shell=True存在安全风险，如果命令中包含用户输入的内容，可能会触发命令注入，所以只建议在可控场景下使用。

最后提醒下：你可以先把Sqoop命令的完整输出捕获下来，确认是不是只有Accumulo警告而没有真正的错误——毕竟状态码1也可能是其他问题导致的，先排查清楚更稳妥。

内容的提问来源于stack exchange，提问作者Mayank Mittal