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)