[ https://issues.apache.org/jira/browse/FLINK-17848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Flink Jira Bot updated FLINK-17848: ----------------------------------- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major stale-minor) Priority: Not a Priority (was: Minor) This issue was labeled "stale-minor" 7 days ago and has not received any updates so it is being deprioritized. If this ticket is actually Minor, please raise the priority and ask a committer to assign you the issue or revive the public discussion. > Allow scala datastream api to create named sources > -------------------------------------------------- > > Key: FLINK-17848 > URL: https://issues.apache.org/jira/browse/FLINK-17848 > Project: Flink > Issue Type: Improvement > Components: API / DataStream, API / Scala > Reporter: Zack LB > Priority: Not a Priority > Labels: auto-deprioritized-major, auto-deprioritized-minor > > Currently you can only provide a custom name to a source operator from the > java API. There is no matching API on the scala API. It would be nice to > allow scala to also name sources something custom. > I'm referring to this [api specifically|#L640] > The change would be as simple as adding a default parameter to that method > which mirrors the java api's default value "Custom Source". Or if preferred > could duplicate the method with a required argument that then passes the > value to the java function. -- This message was sent by Atlassian Jira (v8.20.1#820001)