Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-7857

Portable Wordcount on Flink runner finishes but does not produce output files in DOCKER execution mode

    XMLWordPrintableJSON

    Details

      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: Ahmet Altay Ankur Goenka Kyle Weaver Robert Bradshaw

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              tvalentyn Valentyn Tymofieiev
            • Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

              • Created:
                Updated: