You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by he...@apache.org on 2019/12/29 15:17:32 UTC

[flink] branch release-1.9 updated: [FLINK-15435][python] Fix unstable test for ExecutionConfigTests.test_equals_and_hash

This is an automated email from the ASF dual-hosted git repository.

hequn pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.9 by this push:
     new 2079f8d  [FLINK-15435][python] Fix unstable test for ExecutionConfigTests.test_equals_and_hash
2079f8d is described below

commit 2079f8d20d90afaf2da8195d647b0e9e2c005b0e
Author: libenchao <li...@gmail.com>
AuthorDate: Sun Dec 29 18:34:05 2019 +0800

    [FLINK-15435][python] Fix unstable test for ExecutionConfigTests.test_equals_and_hash
    
    The default parallelism used by local environments is calculated according to the available
    processors. We should specify the parallelism explicitly to avoid test unstable.
    
    This closes #10715.
---
 flink-python/pyflink/common/tests/test_execution_config.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-python/pyflink/common/tests/test_execution_config.py b/flink-python/pyflink/common/tests/test_execution_config.py
index 972edd2..0b692b8 100644
--- a/flink-python/pyflink/common/tests/test_execution_config.py
+++ b/flink-python/pyflink/common/tests/test_execution_config.py
@@ -287,6 +287,7 @@ class ExecutionConfigTests(PyFlinkTestCase):
         self.assertEqual(hash(config1), hash(config2))
 
         config1.set_parallelism(12)
+        config2.set_parallelism(11)
 
         self.assertNotEqual(config1, config2)