flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dia...@apache.org
Subject [flink] branch master updated: [FLINK-23742][python] Fix instable test test_keyed_co_process
Date Fri, 13 Aug 2021 05:46:06 GMT
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 <dianfu@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)],

Mime
View raw message