[ https://issues.apache.org/jira/browse/FLINK-35249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Wei Yuan updated FLINK-35249: ----------------------------- Description: I notice DataGeneratorSource with Java has submitted in "flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/source/DataGeneratorSource.java". We could implement it in PyFlink, since flink-python component is not very active recently, please assign it to me, I will create a PR for this. was: I notice DataGeneratorSource with Java has submitted in "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGeneratorSource.java". We could implement it in PyFlink, since flink-python component is not very active recently, please assign it to me, I will create a PR for this. > Support DataGeneratorSource in PyFlink > -------------------------------------- > > Key: FLINK-35249 > URL: https://issues.apache.org/jira/browse/FLINK-35249 > Project: Flink > Issue Type: Improvement > Components: API / Python > Reporter: Wei Yuan > Priority: Major > > I notice DataGeneratorSource with Java has submitted in > "flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/source/DataGeneratorSource.java". > We could implement it in PyFlink, since flink-python component is not very > active recently, please assign it to me, I will create a PR for this. -- This message was sent by Atlassian Jira (v8.20.10#820010)