Zhipeng Zhang created FLINK-31374:
-------------------------------------
Summary: ProxyStreamPartitioner should implement
ConfigurableStreamPartitioner
Key: FLINK-31374
URL: https://issues.apache.org/jira/browse/FLINK-31374
Project: Flink
Issue Type: Bug
Components: Library / Machine Learning
Affects Versions: ml-2.2.0
Reporter: Zhipeng Zhang
In flink-ml-iterations module, we use ProxyStreamPartitioner to wrap
StreamPartitioner to deal with records in iterations.
However, it did not implement ConfigurableStreamPartitioner interface. Thus
that maxParallelism information is lost.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
