You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2021/08/13 05:46:06 UTC
[flink] branch master updated: [FLINK-23742][python] Fix instable
test test_keyed_co_process
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 37df9b7 [FLINK-23742][python] Fix instable test test_keyed_co_process
37df9b7 is described below
commit 37df9b70d82ce73b43035530787630d0a707c16b
Author: Dian Fu <di...@apache.org>
AuthorDate: Fri Aug 13 13:44:11 2021 +0800
[FLINK-23742][python] Fix instable test test_keyed_co_process
---
flink-python/pyflink/datastream/tests/test_data_stream.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-python/pyflink/datastream/tests/test_data_stream.py b/flink-python/pyflink/datastream/tests/test_data_stream.py
index 745a834..097428d 100644
--- a/flink-python/pyflink/datastream/tests/test_data_stream.py
+++ b/flink-python/pyflink/datastream/tests/test_data_stream.py
@@ -184,8 +184,8 @@ class DataStreamTests(object):
expected = ['4', '5', '6', '7', '8', '3', '5', '7', '9', '11', '3', '5', '7', '9', '11']
self.assert_equals_sorted(expected, results)
- @unittest.skip("FLINK-23742")
def test_keyed_co_process(self):
+ self.env.set_parallelism(1)
ds1 = self.env.from_collection([("a", 1), ("b", 2), ("c", 3)],
type_info=Types.ROW([Types.STRING(), Types.INT()]))
ds2 = self.env.from_collection([("b", 2), ("c", 3), ("d", 4)],