[jira] [Updated] (FLINK-35177) Datagen examples in documentation do not compile
[ https://issues.apache.org/jira/browse/FLINK-35177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-35177: - Fix Version/s: (was: 2.0.0) > 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 >Assignee: Sergei Morozov >Priority: Not a Priority > Labels: pull-request-available > Fix For: 1.20.0, 2.0-preview > > > 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 generatorFunction = index -> index; > double recordsPerSecond = 100; > DataGeneratorSource 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)
[jira] [Updated] (FLINK-35177) Datagen examples in documentation do not compile
[ https://issues.apache.org/jira/browse/FLINK-35177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-35177: - Fix Version/s: 2.0-preview > 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 >Assignee: Sergei Morozov >Priority: Not a Priority > Labels: pull-request-available > Fix For: 2.0.0, 1.20.0, 2.0-preview > > > 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 generatorFunction = index -> index; > double recordsPerSecond = 100; > DataGeneratorSource 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)
[jira] [Updated] (FLINK-35177) Datagen examples in documentation do not compile
[ https://issues.apache.org/jira/browse/FLINK-35177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongqiang Gong updated FLINK-35177: Fix Version/s: 1.20.0 > 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 >Assignee: Sergei Morozov >Priority: Not a Priority > Labels: pull-request-available > Fix For: 2.0.0, 1.20.0 > > > 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 generatorFunction = index -> index; > double recordsPerSecond = 100; > DataGeneratorSource 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)
[jira] [Updated] (FLINK-35177) Datagen examples in documentation do not compile
[ https://issues.apache.org/jira/browse/FLINK-35177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35177: --- Labels: pull-request-available (was: ) > 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 > Labels: pull-request-available > > 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 generatorFunction = index -> index; > double recordsPerSecond = 100; > DataGeneratorSource 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)
[jira] [Updated] (FLINK-35177) Datagen examples in documentation do not compile
[ 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 generatorFunction = index -> index; double recordsPerSecond = 100; DataGeneratorSource 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 generatorFunction = index -> index; double recordsPerSecond = 100; DataGeneratorSource 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 generatorFunction = index -> index; > double recordsPerSecond = 100; > DataGeneratorSource 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)