[BEAM-7857] Portable Wordcount on Flink runner finishes but does not produce output files in DOCKER execution mode

• Type: Bug
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: runner-flink, sdk-py-core
• Labels: portability
• Assignee: Unassigned
• Reporter: Valentyn Tymofieiev
• Created: 31/Jul/19 09:02
• Updated: 04/Jun/22 12:54

Description

Repro steps:

./gradlew :runners:flink:1.5:job-server:runShadow    
./gradlew :sdks:python:container:py3:docker
rm -rf /tmp/py-wordcount-direct*
./gradlew :sdks:python:test-suites:portable:py35:portableWordCountBatch  -PjobEndpoint=localhost:8099 -PenvironmentType=DOCKER
cat /tmp/py-wordcount-direct* # to verify results.

# Output: No such file or directory

Switching to -PenvironmentType=LOOPBACK produces output.
The issue is reproducible both on Py2 and Py3 on master.

cc: altay angoenka ibzib robertwb