В Nifi я использую процессор ExecuteStreamCommand, который вызывает скрипт python и передает flowFile в stdin (игнорировать StdIN: False). Я получаю постоянные ошибки от процессора, даже несмотря на то, что скрипт на Python выполняется правильно и может читать из стандартного ввода. Почему эта ошибка появляется и как я могу отладить / подавить ее?
Failed to write flow file to stdin due to Broken pipe: java.io.IOException: Broken pipe
Панды используются для чтения со стандартного ввода:
df = pd.read_csv(sys.stdin, usecols=schema_map.keys(),
nrows=50, dtype=parse_schema(schema_map))