[
https://issues.apache.org/jira/browse/FLINK-25082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mike Lynch updated FLINK-25082:
-------------------------------
Description:
The official
[documentation|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/rabbitmq/]
states that {{RMQSource}} can have at-least-once processing when "when
checkpointing is enabled, but correlation ids are not used or the source is
parallel." However, as {{RMQSource}} does not implement
{{{}ParallelSourceFunction{}}}, {{StreamExecutionEnvironment}} will throw an
exception whenever parallelism is set to a value higher than 1.
Either the documentation should be corrected or {{RMQSource}} should implement
{{{}ParallelSourceFunction{}}}.
Implementing it seems like it should be fairly easy and I'd be willing to
submit a patch, but as I'm new to the Flink code base I'm not sure if there
would be unexpected side effects. If I can get feedback from more experienced
contributors, I'll submit a patch in the near future.
was:
The official
[documentation|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/rabbitmq/]
states that{{ RMQSource}} can have at-least-once processing when "when
checkpointing is enabled, but correlation ids are not used or the source is
parallel." However, as {{RMQSource}} does not implement
{{{}ParallelSourceFunction{}}}, {{StreamExecutionEnvironment}} will throw an
exception whenever parallelism is set to a value higher than 1.
Either the documentation should be corrected or {{RMQSource}} should implement
{{{}ParallelSourceFunction{}}}.
Implementing it seems like it should be fairly easy and I'd be willing to
submit a patch, but as I'm new to the Flink code base I'm not sure if there
would be unexpected side effects. If I can get feedback from more experienced
contributors, I'll submit a patch in the near future.
> RMQSource is not parallel
> -------------------------
>
> Key: FLINK-25082
> URL: https://issues.apache.org/jira/browse/FLINK-25082
> Project: Flink
> Issue Type: Bug
> Components: Connectors/ RabbitMQ
> Reporter: Mike Lynch
> Priority: Minor
>
> The official
> [documentation|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/rabbitmq/]
> states that {{RMQSource}} can have at-least-once processing when "when
> checkpointing is enabled, but correlation ids are not used or the source is
> parallel." However, as {{RMQSource}} does not implement
> {{{}ParallelSourceFunction{}}}, {{StreamExecutionEnvironment}} will throw an
> exception whenever parallelism is set to a value higher than 1.
> Either the documentation should be corrected or {{RMQSource}} should
> implement {{{}ParallelSourceFunction{}}}.
> Implementing it seems like it should be fairly easy and I'd be willing to
> submit a patch, but as I'm new to the Flink code base I'm not sure if there
> would be unexpected side effects. If I can get feedback from more experienced
> contributors, I'll submit a patch in the near future.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
