[ https://issues.apache.org/jira/browse/FLINK-35177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sergei Morozov updated FLINK-35177: ----------------------------------- Description: Currently, the [examples|https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/connectors/datastream/datagen/#rate-limiting] look like this: {code:java} GeneratorFunction<Long, Long> generatorFunction = index -> index; double recordsPerSecond = 100; DataGeneratorSource<String> source = new DataGeneratorSource<>( generatorFunction, Long.MAX_VALUE, RateLimiterStrategy.perSecond(recordsPerSecond), Types.STRING); {code} The generator function returns Long but the DataGeneratorSource uses String, so their types do not match. Either the generator function needs to be changed to return a string, or the source needs to use Long. was: Currently, the examples look like this: {code} GeneratorFunction<Long, Long> generatorFunction = index -> index; double recordsPerSecond = 100; DataGeneratorSource<String> source = new DataGeneratorSource<>( generatorFunction, Long.MAX_VALUE, RateLimiterStrategy.perSecond(recordsPerSecond), Types.STRING); {code} The generator function returns Long but the DataGeneratorSource uses String, so their types do not match. Either the generator function needs to be changed to return a string, or the source needs to use Long. > Datagen examples in documentation do not compile > ------------------------------------------------ > > Key: FLINK-35177 > URL: https://issues.apache.org/jira/browse/FLINK-35177 > Project: Flink > Issue Type: Bug > Components: Documentation > Affects Versions: 1.19.0 > Reporter: Sergei Morozov > Priority: Not a Priority > > Currently, the > [examples|https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/connectors/datastream/datagen/#rate-limiting] > look like this: > {code:java} > GeneratorFunction<Long, Long> generatorFunction = index -> index; > double recordsPerSecond = 100; > DataGeneratorSource<String> source = > new DataGeneratorSource<>( > generatorFunction, > Long.MAX_VALUE, > RateLimiterStrategy.perSecond(recordsPerSecond), > Types.STRING); > {code} > The generator function returns Long but the DataGeneratorSource uses String, > so their types do not match. > Either the generator function needs to be changed to return a string, or the > source needs to use Long. -- This message was sent by Atlassian Jira (v8.20.10#820010)