Sergei Morozov created FLINK-35177:
--------------------------------------

             Summary: 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


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.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to