Biao Liu created FLINK-5980:
-------------------------------
Summary: Expose max-parallelism value in RuntimeContext
Key: FLINK-5980
URL: https://issues.apache.org/jira/browse/FLINK-5980
Project: Flink
Issue Type: Improvement
Components: DataStream API
Reporter: Biao Liu
Assignee: Biao Liu
Priority: Minor
I am implementing a custom source function. I want to keep all progresses in a
ListState to support dynamically scaling just like what FlinkKafkaConsumer did.
And I think the max-parallelism value is ideal length for the ListState in my
scenario. But I realize that currently the max-parallelism value is not visible
to UDF.
I propose exposing the max-parallelism value in RuntimeContext. It will be
useful in dynamically scaling scenario.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
