[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15324345#comment-15324345 ] ASF GitHub Bot commented on FLINK-4002: --- Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2063 > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Fix For: 1.1.0 > > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15323054#comment-15323054 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 Thanks! > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322943#comment-15322943 ] ASF GitHub Bot commented on FLINK-4002: --- Github user zentol commented on the issue: https://github.com/apache/flink/pull/2063 Looks good, I'll merge it later on. > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322852#comment-15322852 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 Is everything ok? Should I look into something else? > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15319051#comment-15319051 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 I think everything should be ready now. I was not able to pinpoint why HDFS worked, I assume `distributeFiles()` copied the complete directory and that is why it worked, but I'm not 100% sure. > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15317087#comment-15317087 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 Yes, I had the same thought looking at the code, I could not figure out why it worked with HDFS... > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15317078#comment-15317078 ] ASF GitHub Bot commented on FLINK-4002: --- Github user zentol commented on the issue: https://github.com/apache/flink/pull/2063 looking at the code right now; i may have figured out why the files aren't copied, but i find it odd that it supposedly works with hdfs. it actually should never copy additional files if no parameters are given. > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15317053#comment-15317053 ] ASF GitHub Bot commented on FLINK-4002: --- Github user zentol commented on the issue: https://github.com/apache/flink/pull/2063 you can add it to this PR as a separate commit. > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15317000#comment-15317000 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 I can confirm that there is a bug in `PythonPlanBinder.java`. When you pass packages to the `runPlan()` function, they are not copied to the temp directory in which `plan.py` file is generated. I manually changed the `prepareFiles()` call to copy the package files, and everything worked fine. Should I open another issue, or just fix it here? This is not only a bug related to the testing infrastructure, but the Python API in general. > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316231#comment-15316231 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 Yes, I know that how python scripts are executed for the test is different. Let me elaborate: Since running the tests are quite costly in my laptop, I normally test my changes executing them in a local instance of Flink 1.0.3, since this is less taxing. Once I complete the changes, I run `mvn verify`. The problem is that when I call `pyflink2.sh test_main.py utils.py, the module that I pass to the test script, is ignored unless I use HDFS, in which case, everything works fine. > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15315849#comment-15315849 ] ASF GitHub Bot commented on FLINK-4002: --- Github user zentol commented on the issue: https://github.com/apache/flink/pull/2063 test files are never copied to the tmp folder regardless of whether HDFS is used or not. This is not a bug, but intended behaviour. You can easily add the utils.py to the test invokation by modifying the call to the PythonPlanBinder.main in PythonPlanBinderTest. it should be as simple as appending "/utils.py" to the call. > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15315835#comment-15315835 ] ASF GitHub Bot commented on FLINK-4002: --- 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. > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15314040#comment-15314040 ] ASF GitHub Bot commented on FLINK-4002: --- Github user zentol commented on the issue: https://github.com/apache/flink/pull/2063 you're right, that falls through. we should add additional checks: - Verify: index is equal to the size of expected values - Verify2: expected is empty > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15314030#comment-15314030 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 Sorry, I said it wrong, it's the opposite. The case that fails in Verify() and Verify2(), is when we have more values in expected than in the resulting DataSet. > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15314028#comment-15314028 ] ASF GitHub Bot commented on FLINK-4002: --- Github user zentol commented on the issue: https://github.com/apache/flink/pull/2063 when we have more data than expected, remove() will be called on an empty list and should throw an exception, no? if you want to execute the python tests you only have to call mvn verify on the flink-python package. ``` cd flink-libraries/flink-python mvn verify ``` > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15314023#comment-15314023 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 I have corrected Verify2(), but there is another case that is not checked, when the resulting datasets have more elements than expected, right now the error will go unnoticed. I also wanted to ask, is there a way to execute only the python tests, since I want to unify the utilities in a file, but without knowing what is the execution path, I cannot make sure if the module will be imported correctly. > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15312111#comment-15312111 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 Ok, I will modify it and commit the corrected version. > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15312048#comment-15312048 ] ASF GitHub Bot commented on FLINK-4002: --- Github user zentol commented on the issue: https://github.com/apache/flink/pull/2063 you are correct, Verify2 should be modified. there are 2 test scripts since most operations are running at the same time, eating up a lot of memory due to the memory-mapped files. putting them all in one can lead to OOM errors. > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15312006#comment-15312006 ] ASF GitHub Bot commented on FLINK-4002: --- GitHub user omaralvarez opened a pull request: https://github.com/apache/flink/pull/2063 [FLINK-4002] [py] Improve testing infraestructure The Verify() test function now does not error out when array elements are missing: ```python env.generate_sequence(1, 5)\ .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() ``` I have also documented test functions. While documenting, two questions arise. First, Verify2 function has no use as is, performing a `if value in self.expected:` before: ```python try: self.expected.remove(value) except Exception: raise Exception() ``` Makes this function useless, since it will never raise and exception, if I am not mistaken. Also, I am not sure why there are two test scripts, `main_test.py` and `main_test2.py`. You can merge this pull request into a Git repository by running: $ git pull https://github.com/omaralvarez/flink py_testing Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/2063.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2063 commit 784a602167f396cdcd1201509d3c122a5a85248f Author: omaralvarezDate: 2016-06-02T09:09:08Z [FLINK-4002] [py] Improve testing infraestructure > [py] Improve testing infraestructure > > > Key: FLINK-4002 > URL: https://issues.apache.org/jira/browse/FLINK-4002 > Project: Flink > Issue Type: Bug > Components: Python API >Affects Versions: 1.0.3 >Reporter: Omar Alvarez >Priority: Minor > Labels: Python, Testing > Original Estimate: 24h > Remaining Estimate: 24h > > The Verify() test function errors out when array elements are missing: > {code} > env.generate_sequence(1, 5)\ > .map(Id()).map_partition(Verify([1,2,3,4], "Sequence")).output() > {code} > {quote} > IndexError: list index out of range > {quote} > There should also be more documentation in test functions. > I am already working on a pull request to fix this. -- This message was sent by Atlassian JIRA (v6.3.4#6332)