Github user omaralvarez commented on the issue:
https://github.com/apache/flink/pull/2063
I have fixed the last errors in the test functions. But, while trying to
refactor the utility code, that now is repeated in both test files, I think I
found another bug.
The thing is that, in order to be able to have another `utils.py` file, we
need to execute the tests as:
`pyflink2.sh test_main.py utlis.py`
Right now, if HDFS is not used, our case with ` env.execute(local=True)`,
the packages are not copied to the temp folder along with the script file, and
the runner fails not being able to locate the module that has been imported. If
we add this module to the `PYTHONPATH`everything works fine, but I believe this
should happen. This is probably a matter for another JIRA issue altogether.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
