Vancior commented on code in PR #22003:
URL: https://github.com/apache/flink/pull/22003#discussion_r1124011456
##########
flink-python/pyflink/datastream/tests/test_data_stream.py:
##########
@@ -589,6 +589,40 @@ def process_element2(self, value, ctx:
'CoProcessFunction.Context'):
side_expected = ['0', '0', '1', '1', '2', '3']
self.assert_equals_sorted(side_expected, side_sink.get_results())
+ def test_co_broadcast_side_output(self):
+ tag = OutputTag("side", Types.INT())
+
+ class MyBroadcastProcessFunction(BroadcastProcessFunction):
+
+ def process_element(self, value, ctx):
+ yield value[0]
+ yield tag, value[1]
+
+ def process_broadcast_element(self, value, ctx):
+ yield value[1]
+ yield tag, value[0]
+
+ self.env.set_parallelism(2)
Review Comment:
This is kind of an "explict reminder" that tells we expect the output result
should match parallelism=2 with some elements duplicated.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
